Krapi Shah
10/06/2021, 6:45 PMEvan Curtin
10/06/2021, 7:39 PMEddie
10/07/2021, 6:17 PMprefect run -m flows.dev.parent_child -n parent
and got the following exception:
└── 14:10:26 | ERROR | Task 'create_flow_run': Exception encountered during task execution!
Traceback (most recent call last):
File "/Users/epantridge/Library/Caches/pypoetry/virtualenvs/flows-Lt6Mru_j-py3.9/lib/python3.9/site-packages/prefect/engine/task_runner.py", line 859, in get_task_run_state
value = prefect.utilities.executors.run_task_with_timeout(
File "/Users/epantridge/Library/Caches/pypoetry/virtualenvs/flows-Lt6Mru_j-py3.9/lib/python3.9/site-packages/prefect/utilities/executors.py", line 454, in run_task_with_timeout
return task.run(*args, **kwargs) # type: ignore
File "/Users/epantridge/Library/Caches/pypoetry/virtualenvs/flows-Lt6Mru_j-py3.9/lib/python3.9/site-packages/prefect/tasks/prefect/flow_run.py", line 118, in create_flow_run
flow = FlowView.from_flow_name(flow_name, project_name=project_name)
File "/Users/epantridge/Library/Caches/pypoetry/virtualenvs/flows-Lt6Mru_j-py3.9/lib/python3.9/site-packages/prefect/backend/flow.py", line 192, in from_flow_name
flows = cls._query_for_flows(
File "/Users/epantridge/Library/Caches/pypoetry/virtualenvs/flows-Lt6Mru_j-py3.9/lib/python3.9/site-packages/prefect/backend/flow.py", line 287, in _query_for_flows
raise ValueError(
ValueError: No results found while querying for flows where {'name': {'_eq': 'child'}, 'archived': {'_eq': False}}
Does this imply that the child flow has to be registered before the parent flow can be run? If so, is there a way to register a flow in-process when testing locally?Ramzi A
10/07/2021, 8:15 PMSylvain Hazard
10/08/2021, 8:54 AMFilip Lindvall
10/08/2021, 12:36 PMSylvain Hazard
10/08/2021, 2:49 PMCooper Marcus
10/09/2021, 3:20 PMScarlett King
10/12/2021, 10:02 AMJohnny
10/12/2021, 4:20 PMCasey Green
10/12/2021, 9:55 PMMartin Felder
10/13/2021, 4:31 PMapollo_1 | PayloadTooLargeError: request entity too large
apollo_1 | at readStream (/apollo/node_modules/raw-body/index.js:155:17)
apollo_1 | at getRawBody (/apollo/node_modules/raw-body/index.js:108:12)
apollo_1 | at read (/apollo/node_modules/body-parser/lib/read.js:77:3)
apollo_1 | at jsonParser (/apollo/node_modules/body-parser/lib/types/json.js:135:5)
apollo_1 | at Layer.handle [as handle_request] (/apollo/node_modules/express/lib/router/layer.js:95:5)
apollo_1 | at trim_prefix (/apollo/node_modules/express/lib/router/index.js:317:13)
apollo_1 | at /apollo/node_modules/express/lib/router/index.js:284:7
apollo_1 | at Function.process_params (/apollo/node_modules/express/lib/router/index.js:335:12)
apollo_1 | at next (/apollo/node_modules/express/lib/router/index.js:275:10)
apollo_1 | at cors (/apollo/node_modules/cors/lib/index.js:188:7)
every 2 seconds or so. The server UI also does not seem to be running. Does anyone have an idea what this means?Lon Nix
10/13/2021, 5:02 PMJimmy Borzillieri
10/14/2021, 8:11 PMLon Nix
10/14/2021, 8:55 PMprefect config server.host="<http://blah>"
prefect config server.port="4200"
Alexander van Eck
10/15/2021, 12:12 PMLon Nix
10/15/2021, 3:11 PMCasey Green
10/16/2021, 12:54 PMSylvain Hazard
10/18/2021, 9:20 AMSylvain Hazard
10/18/2021, 11:56 AMAleksandr Glushko
10/19/2021, 8:38 AMTask 'init_ray': Exception encountered during task execution!
Traceback (most recent call last):
File "/usr/local/lib/python3.7/site-packages/prefect/engine/task_runner.py", line 865, in get_task_run_state
logger=self.logger,
File "/usr/local/lib/python3.7/site-packages/prefect/utilities/executors.py", line 328, in run_task_with_timeout
return task.run(*args, **kwargs) # type: ignore
File "<string>", line 57, in init_ray
File "/usr/local/lib/python3.7/site-packages/ray/_private/client_mode_hook.py", line 62, in wrapper
return func(*args, **kwargs)
File "/usr/local/lib/python3.7/site-packages/ray/worker.py", line 844, in init
connect_only=True)
File "/usr/local/lib/python3.7/site-packages/ray/node.py", line 166, in __init__
self._init_temp(redis_client)
File "/usr/local/lib/python3.7/site-packages/ray/node.py", line 283, in _init_temp
session_dir = _get_with_retry(redis_client, "session_dir")
File "/usr/local/lib/python3.7/site-packages/ray/node.py", line 41, in _get_with_retry
result = redis_client.get(key)
File "/usr/local/lib/python3.7/site-packages/redis/client.py", line 1606, in get
return self.execute_command('GET', name)
File "/usr/local/lib/python3.7/site-packages/redis/client.py", line 901, in execute_command
return self.parse_response(conn, command_name, **options)
File "/usr/local/lib/python3.7/site-packages/redis/client.py", line 915, in parse_response
response = connection.read_response()
File "/usr/local/lib/python3.7/site-packages/redis/connection.py", line 756, in read_response
raise response
redis.exceptions.ResponseError: WRONGTYPE Operation against a key holding the wrong kind of value
I can initialize it internally in the Ray service, but there is a problem in connection between the srvicesSylvain Hazard
10/19/2021, 8:58 AMa = A()
b = B.map(a)
c = C.map(b)
and I would like to prevent C mapped tasks from being created if the upstream B mapped task is Failed.
I have tried using a FilterTask which works great but serves as a kind of reducing task which stops depth first execution from working as I would like it to. Is there another way to do this while still making use of DFE ?Raúl Mansilla
10/19/2021, 9:58 AMAJ
10/19/2021, 10:37 AMSylvain Hazard
10/19/2021, 2:44 PMPayam Vaezi
10/20/2021, 6:02 PMRitvik Mishra
10/20/2021, 10:00 PMTara
10/21/2021, 11:51 PMFailed to set task state with error: ReadTimeout(ReadTimeoutError("HTTPConnectionPool(host='localhost', port=4200): Read timed out. (read timeout=15)"))
This has been an ongoing issue, anyone has any idea on how to fix this?Arun Dass
10/22/2021, 5:20 PMGabriel Milan
10/22/2021, 6:26 PMGabriel Milan
10/22/2021, 6:26 PMKevin Kho
10/22/2021, 6:28 PMGabriel Milan
10/22/2021, 6:29 PMAnna Geller
10/22/2021, 7:45 PMGabriel Milan
10/22/2021, 7:50 PMKevin Kho
10/22/2021, 7:52 PMGabriel Milan
10/22/2021, 7:57 PM