Daniel Lomartra
06/03/2022, 1:03 AMKevin Kho
06/03/2022, 1:18 AMDaniel Lomartra
06/03/2022, 1:52 AMupdate_sync_time = create_flow_run.map(
flow_name = unmapped("dbt"),
project_name = unmapped(PROJECT_NAME),
task_args= unmapped({"name":"Update Sync Time in Database"}),
parameters=portco
)
update_sync_time_wait = wait_for_flow_run.map(
update_sync_time, raise_final_state=unmapped(True), task_args=unmapped({"name":"Update Sync Time in Database - Wait"})
)
Traceback (most recent call last):
File "C:\Users\DLomartra\source\repos\MEP2\prefect-cloud\01_main\flows\parent_flows\dbt-parent.py", line 65, in <module>
update_sync_time = create_flow_run.map(
File "C:\Users\DLomartra\source\repos\MEP2\prefect-cloud\01_main\lib\site-packages\prefect\core\task.py", line 810, in map
task_args = task_args.copy() if task_args else {}
AttributeError: 'unmapped' object has no attribute 'copy'
Kevin Kho
06/03/2022, 1:56 AMfrom prefect.tasks.prefect import create_flow_run
create_flow_run.name = "Update Sync Time in Database"
with Flow(..) as flow:
create_flow_run.map(...)
Daniel Lomartra
06/03/2022, 4:50 PMKevin Kho
06/03/2022, 5:02 PMtask_run_name
instead like this ? You could also copy the task
from prefect.tasks.prefect import create_flow_run
from copy import copy
c1 = copy(create_flow_run)
c1.name = ...