Mac Gréco Péralte Chéry
07/04/2020, 1:38 AMJeremiah
07/04/2020, 1:41 AMMac Gréco Péralte Chéry
07/04/2020, 2:08 AMJeremiah
07/04/2020, 2:34 AMMac Gréco Péralte Chéry
07/04/2020, 4:34 PMuly 3rd 2020 at 10:56:25pm | prefect.CloudTaskRunner
ERROR lens
Unexpected error: SystemError('unknown opcode',)
Traceback (most recent call last):
File "/home/ubuntu/.local/lib/python3.6/site-packages/prefect/engine/runner.py", line 48, in inner
new_state = method(self, state, *args, **kwargs)
File "/home/ubuntu/.local/lib/python3.6/site-packages/prefect/engine/task_runner.py", line 822, in get_task_run_state
self.task.run, timeout=self.task.timeout, **raw_inputs
File "/home/ubuntu/.local/lib/python3.6/site-packages/prefect/utilities/executors.py", line 186, in timeout_handler
return fn(*args, **kwargs)
File "C:/Users/Admin/PycharmProjects/project/app.py", line 12, in basic_task
File "C:/Users/Admin/PycharmProjects/project/app.py", line 23, in base_task
SystemError: unknown opcode
Jeremiah
07/04/2020, 5:16 PMMac Gréco Péralte Chéry
07/05/2020, 1:18 AMJuly 4th 2020 at 9:14:43pm | prefect.CloudTaskRunner
ERROR lens
Unexpected error: RuntimeError('Attempting to call `flow.register` during execution of flow file will lead to unexpected results.')
from prefect import task, Flow
from prefect import Client
@task
def basic_task():
client = Client( "<http://localhost:4200/graphql>")
f = Flow("childFlow")
client.register(flow=f, build=False)
return
with Flow(name="MasterFlow") as masterFlow:
basic_task()
I will continue to update the code (S3 storage, parameters etc ...) and see if it still work.