Jeff Wang
03/01/2024, 7:02 PM@op(
required_resource_keys={"dd_logger", "dd_tracer"},
out=Out(int, io_manager_key="df_io_manager"),
)
def facility_ba(
context: OpExecutionContext,
) -> int:
return 1
The error:
dagster._core.errors.DagsterInvalidDefinitionError: Cannot annotate `context` parameter with type OpExecutionContext. `context` must be annotated with AssetExecutionContext, OpExecutionContext, or left blank.
Jeff Wang
03/01/2024, 8:15 PMfrom __future__ import annotations
, which apparently doesn’t play well with dagster 1.5+