We have deployment, which has a flow named cleanse-like-flow. We trigger the flow using run_deployment as below:
flow_run = await run_deployment(
name="cleanse-like-flow/cleanse-like", parameters=dict(numbers=[1, 2, 3])
)
The output is a Flow Run object and we would like to get the result of the flow from this object. We have tried to extract it using -
flow_run = await run_deployment(
name="cleanse-like-flow/cleanse-like", parameters=dict(numbers=[1, 2, 3])
)
print(f"Flow Run: {flow_run}")
state = flow_run.state
output = state.result()
Output:
Flow Run: id=UUID('<REDACTED>') name='competent-boar' flow_id=UUID('<REDACTED>') state_id=UUID('<REDACTED>') deployment_id=UUID('<REDACTED>') work_queue_name='default' flow_version='<REDACTED>' parameters={'numbers': [1, 2, 3]} idempotency_key=None context={} empirical_policy=FlowRunPolicy(max_retries=0, retry_delay_seconds=0.0, retries=0, retry_delay=0, pause_keys=set(), resuming=False) tags=[] parent_task_run_id=None run_count=1 expected_start_time=DateTime(2023, 9, 20, 13, 19, 26, 441348, tzinfo=Timezone('+00:00')) next_scheduled_start_time=None start_time=DateTime(2023, 9, 20, 13, 19, 40, 134797, tzinfo=Timezone('+00:00')) end_time=DateTime(2023, 9, 20, 13, 19, 41, 122628, tzinfo=Timezone('+00:00')) total_run_time=datetime.timedelta(microseconds=987831) estimated_run_time=datetime.timedelta(microseconds=987831) estimated_start_time_delta=datetime.timedelta(seconds=13, microseconds=693449) auto_scheduled=False infrastructure_document_id=UUID('<REDACTED>') infrastructure_pid='<REDACTED>:prefect2:competent-boar-gvbsq' created_by=None work_queue_id=UUID('<REDACTED>') work_pool_id=UUID('<REDACTED>') work_pool_name='default-agent-pool' state=Completed(message=None, type=COMPLETED, result=UnpersistedResult(type='unpersisted', artifact_type=None, artifact_description=None)) state_type=StateType.COMPLETED state_name='Completed'
Flow Output: type='unpersisted' artifact_type=None artifact_description=None
Flow Output Type: <class 'prefect.results.UnpersistedResult'>
How could we extract the result from the flow state. We have tried state.result() as well as state.result.get()