Karim Soliman
09/19/2022, 11:45 PM16 September 2022,01:33:41 prefect.CloudTaskRunner INFO Task 'create_ingestion_params': Starting task run...
16 September 2022,01:33:41 prefect.CloudTaskRunner INFO Task 'create_ingestion_params': Finished task run for task with final state: 'Success'
16 September 2022,01:33:41 prefect.CloudTaskRunner INFO Task 'create_flow_run': Starting task run...
16 September 2022,01:33:41 prefect.CloudTaskRunner INFO Task 'create_flow_run': Finished task run for task with final state: 'Mapped'
16 September 2022,01:33:42 prefect.CloudTaskRunner INFO Task 'create_flow_run[0]': Starting task run...
16 September 2022,01:33:42 prefect.create_flow_run[0] INFO Creating flow run 'fierce-flounder-Tome Ingestion' for flow 'Tome Ingestion'...
16 September 2022,01:33:42 prefect.create_flow_run[0] INFO Created flow run 'fierce-flounder-Tome Ingestion': <https://cloud.prefect.io/tome/flow-run/8d5af013-baa8-4830-be75-7d212a4f3e74>
16 September 2022,01:33:42 prefect.CloudTaskRunner INFO Task 'create_flow_run[0]': Finished task run for task with final state: 'Success'
16 September 2022,01:33:43 prefect.CloudTaskRunner INFO Task 'create_flow_run[1]': Starting task run...
16 September 2022,01:33:43 prefect.create_flow_run[1] INFO Creating flow run 'fierce-flounder-Tome Ingestion' for flow 'Tome Ingestion'...
16 September 2022,01:33:43 prefect.create_flow_run[1] INFO Created flow run 'fierce-flounder-Tome Ingestion': <https://cloud.prefect.io/tome/flow-run/7729a5c3-5fb3-474f-bfbc-7d2fbce841d8>
16 September 2022,01:33:44 prefect.CloudTaskRunner INFO Task 'create_flow_run[1]': Finished task run for task with final state: 'Success'
log from my local python execution
[2022-09-19 23:44:08+0000] INFO - prefect.CloudTaskRunner | Task 'create_ingestion_params': Starting task run...
INFO [task_runner.py:241] Task 'create_ingestion_params': Starting task run...
[2022-09-19 23:44:14+0000] INFO - prefect.CloudTaskRunner | Task 'create_ingestion_params': Finished task run for task with final state: 'Success'
INFO [task_runner.py:335] Task 'create_ingestion_params': Finished task run for task with final state: 'Success'
[2022-09-19 23:44:14+0000] INFO - prefect.CloudTaskRunner | Task 'create_flow_run': Starting task run...
INFO [task_runner.py:241] Task 'create_flow_run': Starting task run...
[2022-09-19 23:44:14+0000] INFO - prefect.CloudTaskRunner | Task 'create_flow_run': Finished task run for task with final state: 'Mapped'
INFO [task_runner.py:335] Task 'create_flow_run': Finished task run for task with final state: 'Mapped'
[2022-09-19 23:44:15+0000] INFO - prefect.CloudTaskRunner | Task 'get_task_run_result': Starting task run...
INFO [task_runner.py:241] Task 'get_task_run_result': Starting task run...
params = create_ingestion_params(documents, clause_snapshot_id, report_id)
ingestion_flows = create_flow_run.map(flow_name=unmapped("Tome Ingestion"), project_name=unmapped("development"), parameters=params)
results = get_task_run_result.map(flow_run_id=ingestion_flows, task_slug=unmapped("get_drr-1"))
Matt Conger
09/20/2022, 12:11 AMKarim Soliman
09/20/2022, 12:28 AMAnna Geller
09/20/2022, 6:27 PMKarim Soliman
09/21/2022, 12:08 AMAnna Geller
09/21/2022, 3:13 AMKarim Soliman
09/21/2022, 11:01 PMAnna Geller
09/22/2022, 12:49 AM