Ha Pham
07/19/2022, 4:35 AMRyan Sattler
07/19/2022, 6:16 AMKyle McChesney
07/19/2022, 5:08 PMAbin Antony
07/19/2022, 11:45 PMMadison Schott
07/20/2022, 3:34 PMMichael Levenson
07/21/2022, 9:49 AMMansour Zayer
07/22/2022, 3:05 PMKaranveer Mohan
07/25/2022, 9:35 PMPrefectHTTPStatusError
for one of my subflow runs. The cloud UI also is in an inconsistent state since it says flow/subflow is still running. It works fine locally. Any help would be appreciated!
Encountered exception during execution:
Traceback (most recent call last):
File "/usr/local/lib/python3.9/site-packages/prefect/engine.py", line 559, in orchestrate_flow_run
result = await run_sync(flow_call)
File "/usr/local/lib/python3.9/site-packages/prefect/utilities/asyncutils.py", line 56, in run_sync_in_worker_thread
return await anyio.to_thread.run_sync(call, cancellable=True)
File "/usr/local/lib/python3.9/site-packages/anyio/to_thread.py", line 31, in run_sync
return await get_asynclib().run_sync_in_worker_thread(
File "/usr/local/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 937, in run_sync_in_worker_thread
return await future
File "/usr/local/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 867, in run
result = context.run(func, *args)
File "/root/deployer/pipeline.py", line 21, in run_ro
etl.run_ro()
File "/usr/local/lib/python3.9/site-packages/prefect/flows.py", line 367, in __call__
return enter_flow_run_engine_from_flow_call(
File "/usr/local/lib/python3.9/site-packages/prefect/engine.py", line 154, in enter_flow_run_engine_from_flow_call
return run_async_from_worker_thread(begin_run)
File "/usr/local/lib/python3.9/site-packages/prefect/utilities/asyncutils.py", line 136, in run_async_from_worker_thread
return anyio.from_thread.run(call)
File "/usr/local/lib/python3.9/site-packages/anyio/from_thread.py", line 49, in run
return asynclib.run_async_from_thread(func, *args)
File "/usr/local/lib/python3.9/site-packages/anyio/_backends/_asyncio.py", line 970, in run_async_from_thread
return f.result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 445, in result
return self.__get_result()
File "/usr/local/lib/python3.9/concurrent/futures/_base.py", line 390, in __get_result
raise self._exception
File "/usr/local/lib/python3.9/site-packages/prefect/client.py", line 104, in with_injected_client
return await fn(*args, **kwargs)
File "/usr/local/lib/python3.9/site-packages/prefect/engine.py", line 454, in create_and_begin_subflow_run
terminal_state = await orchestrate_flow_run(
File "/usr/local/lib/python3.9/contextlib.py", line 670, in __aexit__
raise exc_details[1]
File "/usr/local/lib/python3.9/contextlib.py", line 653, in __aexit__
cb_suppress = await cb(*exc_details)
File "/usr/local/lib/python3.9/contextlib.py", line 199, in __aexit__
await self.gen.athrow(typ, value, traceback)
File "/usr/local/lib/python3.9/site-packages/prefect/engine.py", line 1181, in report_flow_run_crashes
await client.set_flow_run_state(
File "/usr/local/lib/python3.9/site-packages/prefect/client.py", line 1505, in set_flow_run_state
response = await <http://self._client.post|self._client.post>(
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 1842, in post
return await self.request(
File "/usr/local/lib/python3.9/site-packages/httpx/_client.py", line 1527, in request
return await self.send(request, auth=auth, follow_redirects=follow_redirects)
File "/usr/local/lib/python3.9/site-packages/prefect/client.py", line 277, in send
response.raise_for_status()
File "/usr/local/lib/python3.9/site-packages/prefect/client.py", line 223, in raise_for_status
raise PrefectHTTPStatusError.from_httpx_error(exc) from exc.__cause__
prefect.exceptions.PrefectHTTPStatusError: Server error '503 Service Unavailable' for url '<https://api-beta.prefect.io/api/accounts/cf175afc-09c0-4bc3-bdba-2ad01653e8ea/workspaces/7eb80c34-5efe-4f01-9ee9-64715100b7e3/flow_runs/29563420-7c6f-4680-97bf-14d148d06ee7/set_state>'
For more information check: <https://httpstatuses.com/503>
02:01:18 PM
Crash detected! Execution was interrupted by an unexpected exception.
Rajvir Jhawar
07/28/2022, 9:36 AM[ { "op": "add", "path": "/spec/template/spec/resources", "value": {"limits": {"memory": "512Mi", "cpu": "250m", "ephemeral-storage": "100Mi"}} }, { "op": "add", "path": "/spec/ttlSecondsAfterFinished","value": 10}]
Also Customization is a spec based on the JSON standard. It is strange that it is using a text field and not a json field.Rajvir Jhawar
07/29/2022, 12:42 AMRajvir Jhawar
07/29/2022, 12:46 AMMars
07/29/2022, 3:46 PMAgent ID
. However the agent container logs don’t provide any identifying information. How do I know that the Kubernetes agent I am looking at in the cluster is the same agent I see in the UI?Martim Lobao
07/29/2022, 5:17 PMFailed to retrieve task state with error: ClientError([{'path': ['get_or_create_task_run_info'], 'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'extensions': {'code': 'INTERNAL_SERVER_ERROR', 'exception': {'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'locations': [{'line': 2, 'column': 101}], 'path': None}}}])
Traceback (most recent call last):
File "/root/.pex/venvs/s/fb4b0edf/venv/lib/python3.9/site-packages/prefect/engine/cloud/task_runner.py", line 154, in initialize_run
task_run_info = self.client.get_task_run_info(
File "/root/.pex/venvs/s/fb4b0edf/venv/lib/python3.9/site-packages/prefect/client/client.py", line 1798, in get_task_run_info
result = self.graphql(mutation) # type: Any
File "/root/.pex/venvs/s/fb4b0edf/venv/lib/python3.9/site-packages/prefect/client/client.py", line 569, in graphql
raise ClientError(result["errors"])
prefect.exceptions.ClientError: [{'path': ['get_or_create_task_run_info'], 'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'extensions': {'code': 'INTERNAL_SERVER_ERROR', 'exception': {'message': 'Expected type UUID!, found ""; Could not parse UUID: ', 'locations': [{'line': 2, 'column': 101}], 'path': None}}}]
this might be related to a change we made to the flow: we now have a more recent version of the flow, and the failed flow is an older versionSurawut Jirasaktavee
07/30/2022, 3:58 PMprefect deployment --help
. I don’t see build
or apply
Chu
07/31/2022, 8:38 PMJohn
08/01/2022, 1:53 AMRajvir Jhawar
08/01/2022, 9:00 AMChu
08/01/2022, 1:32 PMcreate_flow_run(
flow_name="xxx",
project_name="xxx",
parameters = params,
run_name = 'cw1234'
)
Kelby
08/01/2022, 1:59 PMfrom prefect import flow, task
from prefect import tags
@task
def my_task():
print("Hello, I'm a task")
@flow
def my_flow():
with tags("test"):
my_task()
When I run this, the test
tag doesn’t get set.Stefan
08/02/2022, 9:32 AMValilth Ibrahim Aliyar
08/02/2022, 2:25 PMMaximilian Schnieder
08/02/2022, 5:30 PMChu
08/02/2022, 7:47 PMMars
08/02/2022, 8:45 PM<Failed: "Some reference tasks failed.">
message. When I have nested flows how can I quickly navigate from the parent flow to the failed child flow and directly to its failed tasks? This is using Prefect 1.0.Mohamed Alaa
08/03/2022, 1:26 PMLate
State it seems to remove all the Flows for the List. Is that some kind of bug?
Thanks a lot!massintha azamoum
08/03/2022, 7:12 PMWilliam Jamir
08/04/2022, 5:31 PMfrojo
08/05/2022, 2:33 PMfrom prefect.infrastructure.docker import DockerContainer, ImagePullPolicy
docker_block = DockerContainer(image="some-image",
image_pull_policy=ImagePullPolicy.ALWAYS,env=dict(PREFECT_LOGGING_LEVEL="DEBUG"))
docker_block.save("docker-image")
However if I add the block from the UI the change is reflected and shown.
Any advice?Rajvir Jhawar
08/05/2022, 3:38 PMRaviraj Dixit
08/06/2022, 12:14 PMNo such command 'auth'.
can anyone help me with this?
Additional information, I am using prefect 2.0.3 version and trying to run
prefect auth login --key <YOUR-KEY>