Guy McCombe
01/30/2023, 7:23 PM@op(
...
ins={"df": In(input_manager_key="io_manager")}
)
def op_fn(context, df: DataFrame):
...
Where "io_manager"
is an io manager with a load_input
function. However, this raises a code location error: DagsterInvalidDefinitionError: Input 'df' of op 'op_fn' has no way of being resolved. Must provide a resolution to this input via another op/graph, or via a direct input value mapped from the top-level graph. To learn more, see the docs for unconnected inputs: <https://docs.dagster.io/concepts/io-management/unconnected-inputs#unconnected-inputs>.
Any ideas on what I’m missing? It looks valid in comparison to the linked docsGuy McCombe
01/31/2023, 11:40 AMjamie
01/31/2023, 3:39 PMGuy McCombe
01/31/2023, 3:41 PMdf: DataFrame
- I suppose that by giving it a type hint in the arguments instead of in the In
object it didn’t connect the unconnected input with the argument providedGuy McCombe
01/31/2023, 3:42 PM@op(
ins={"df": In(input_manager_key="io_manager", dagster_type=...)}
)
def op_fn(context, df):
...
jamie
01/31/2023, 5:51 PMGuy McCombe
01/31/2023, 5:51 PM