Don
04/29/2022, 8:42 PMdagster.core.errors.DagsterInvalidInvocationError: Compute function of solid '00' has context argument, but no context was provided when invoking.
@op
def airbyte_it(context):
print(context.op_config["it"])
@op
def call_it(ids):
for airbtye_id in ids:
airbyte_it.configured({"it": airbtye_id}, name=str(airbtye_id))()
chris
04/29/2022, 8:47 PMDon
05/02/2022, 12:24 AMdef _for_each(val):
airbyte_it.configured({"it": val}, name=str(val))()
results = dynamic_workspace().map(_for_each)
and this option gives the following error:
dagster.core.errors.DagsterInvalidInvocationError: Compute function of solid '40' has context argument, but no context was provided when invoking.
results = dynamic_workspace().map(pass_airbyte)
@op
def pass_airbyte(this):
airbyte_it.configured({"id": this}, name=str(this))()
Any insight into how I can call an op with configured for a dynamic output?
Thanks in advance.