Pedro Machado
01/24/2022, 4:38 PMwait_for_flow_run
task when trying to implement a flow of flows:
Unexpected error: TypeError('Object of type FlowRunView is not JSON serializable')
Any ideas? Code in thread.Kevin Kho
wait_for_flow_run
throws the error?Pedro Machado
01/24/2022, 4:56 PMFlow 'cherubic-rhino-get_employee_listings': Entered state <Success>: All reference tasks succeeded.
10:35:11
ERROR
CloudTaskRunner
Unexpected error: TypeError('Object of type FlowRunView is not JSON serializable')
Traceback (most recent call last):
File "/usr/local/lib/python3.8/site-packages/prefect/engine/runner.py", line 48, in inner
new_state = method(self, state, *args, **kwargs)
File "/usr/local/lib/python3.8/site-packages/prefect/engine/task_runner.py", line 926, in get_task_run_state
result = self.result.write(value, **formatting_kwargs)
File "/usr/local/lib/python3.8/site-packages/prefect/engine/results/prefect_result.py", line 62, in write
new.location = self.serializer.serialize(new.value).decode("utf-8")
File "/usr/local/lib/python3.8/site-packages/prefect/engine/serializers.py", line 110, in serialize
return json.dumps(value).encode()
File "/usr/local/lib/python3.8/json/__init__.py", line 231, in dumps
return _default_encoder.encode(obj)
File "/usr/local/lib/python3.8/json/encoder.py", line 199, in encode
chunks = self.iterencode(o, _one_shot=True)
File "/usr/local/lib/python3.8/json/encoder.py", line 257, in iterencode
return _iterencode(o, 0)
File "/usr/local/lib/python3.8/json/encoder.py", line 179, in default
raise TypeError(f'Object of type {o.__class__.__name__} '
TypeError: Object of type FlowRunView is not JSON serializable
Kevin Kho
PrefectResult()
right? It is trying to save the task output as a result.Pedro Machado
01/24/2022, 5:05 PMwait_for_flow_run
returns FlowRunView
Kevin Kho
create_flow_run.checkpoint=False
Pedro Machado
01/24/2022, 5:06 PMwait_for_flow_run.checkpoint=False
?Kevin Kho
Pedro Machado
01/24/2022, 5:23 PMKevin Kho
Pedro Machado
01/24/2022, 5:39 PMKevin Kho