Constantino Schillebeeckx09/28/2021, 5:54 PM
mount_glue_catalog.run(schema_name=schema_name, glue_db=glue_db_name, upstream_tasks=[create_catalog])
is the return from another task. When I execute this I'm getting
When I call this from a flow context, the invocation of
TypeError: mount_glue_catalog() got an unexpected keyword argument 'upstream_tasks'
doesn't have any issues. Does the interface to running this task somehow change based on my calling it with run() vs from within a flow context?
kwargs when calling run like this, but in general I don’t think you can because using a task like this is just the underlying Python function. With
specifically, there is a disconnect where
is a build-time concept as the DAG is created and using a task in another task is a run-time thing and you can’t create the dependency during runtime. The
should go in the
Constantino Schillebeeckx09/28/2021, 6:24 PM