Yehuda Ornstein
02/07/2023, 6:27 PMfrom dagster import job, op, Definitions
@op(required_resource_keys={"database"})
def op_requires_resources(context):
database_resource = context.resources.database
<http://context.log.info|context.log.info>(database_resource)
@job()
def demo_job():
op_requires_resources()
defs = Definitions(
jobs=[demo_job],
resources={
"database": "test_resource",
}
)
however, I'm getting the following error:
dagster._core.errors.DagsterInvalidDefinitionError: resource with key 'database' required by op 'op_requires_resources' was not provided. Please provide a <class 'dagster._core.definitions.resource_definition.ResourceDefinition'> to key 'database', or change the required key to one of the following keys which points to an <class 'dagster._core.definitions.resource_definition.ResourceDefinition'>: ['io_manager']
what am I doing wrong here?Terry Lines
02/07/2023, 7:22 PM@resource
def test_resource(init_context):
...
Yehuda Ornstein
02/07/2023, 7:30 PMYehuda Ornstein
02/07/2023, 7:53 PMdefs = Definitions(
jobs=[demo_job],
resources={
"database": "test_resource",
}
)
in:
@resource
def test_resource(init_context):
Terry Lines
02/07/2023, 8:03 PM