Dylan
05/19/2022, 10:22 PM[2022-05-19 22:18:54+0000] DEBUG - prefect.CloudTaskRunner | Task 'my-foobar-task': Calling task.run() method...
[2022-05-19 22:19:38+0000] DEBUG - prefect.CloudFlowRunner | Checking flow run state...
[2022-05-19 22:19:53+0000] DEBUG - prefect.CloudFlowRunner | Checking flow run state...
with Flow(
name=FLOW_NAME,
storage=Local(
add_default_labels=False,
stored_as_script=True,
path="flows/asn_ingest.py",
),
run_config=KubernetesRun(
image=f"{ECR_REGISTRY}/{IMAGE}:{IMAGE_TAG}",
labels=[IMAGE, ENV, FLOW_NAME],
job_template_path="templates/base-flow-template.yaml",
),
executor=LocalExecutor(),
) as flow:
client = AsnApiClient()
raw_data = api_get_asn(client)
save(raw_data)
Anna Geller
Dylan
05/19/2022, 10:46 PM59223286-ed94-453a-abf2-c0a94532b637
Anna Geller
Dylan
05/20/2022, 3:15 PMflow_id
not a flow_run_id
flow_run_id
anywhere in the UIAnna Geller
Dylan
05/23/2022, 4:40 PM