Benoît Linsey-Fazi
01/20/2023, 1:36 PMAustin Weisgrau
01/20/2023, 8:28 PMRyan Bermel
01/20/2023, 8:56 PMBen Muller
01/25/2023, 10:06 PMFlows
page when typing into the input to search for a Flow that the text you type gets automatically deleted for about 10 seconds ?Ben Muller
01/25/2023, 11:47 PMCarlos Cueto
01/29/2023, 1:48 PMAppriseNotificationBlock
. I went ahead and registered the custom block I created with the UI and created a block under my Blocks page with the webhook URL.
When I .load()
the block from local python client and call .notify()
on it, it works perfectly. I thought it would work just the same if I add it as an Action on the Automations tab, but to my surprise, it fails every time. I see the failed events on the Events tab of the automation I set up. Is there a way to see what is causing the failure?Carlos Cueto
01/29/2023, 1:54 PMDmitry Sandovich
01/30/2023, 6:33 PMSlackbot
01/30/2023, 7:27 PMThet Naing
02/01/2023, 7:55 PM2.7.10
. I keep getting this error when attempting to run flows. Any idea what's going on?
Flow could not be retrieved from deployment.
Traceback (most recent call last):
File "/usr/local/lib/python3.10/site-packages/prefect/engine.py", line 262, in retrieve_flow_then_begin_flow_run
flow = await load_flow_from_flow_run(flow_run, client=client)
File "/usr/local/lib/python3.10/site-packages/prefect/client/utilities.py", line 47, in with_injected_client
return await fn(*args, **kwargs)
File "/usr/local/lib/python3.10/site-packages/prefect/deployments.py", line 166, in load_flow_from_flow_run
await storage_block.get_directory(from_path=deployment.path, local_path=".")
File "/usr/local/lib/python3.10/site-packages/prefect/filesystems.py", line 916, in get_directory
raise OSError(f"Failed to pull from remote:\n {err_stream.read()}")
OSError: Failed to pull from remote:
Cloning into '/tmp/tmpabasdfprefect'...
fatal: could not read Username for '<https://github.com>': No such device or address
Carlos Cueto
02/03/2023, 3:34 PMFlavio Oliveira
02/06/2023, 11:13 AMJonas
02/06/2023, 11:22 AMJoseph Thickpenny Ryan
02/06/2023, 5:02 PMJoseph Thickpenny Ryan
02/06/2023, 5:54 PMRyan Bermel
02/06/2023, 9:09 PMBlock document has schema checksum <omitted checksum> which does not match the schema checksum for class 'RemoteFileSystem'. This indicates the schema has changed and this block may not load.
return cls._from_block_document(block_document)
Joseph Thickpenny Ryan
02/08/2023, 2:50 PMTim-Oliver
02/09/2023, 10:40 AMCarlos Cueto
02/10/2023, 1:54 PMwork queue
or work pool
in what seems to be random. I liked the old way of seeing the work queue because it gave me an idea of the execution environment of said flow. Is this intended?Tanay Kothari
02/12/2023, 3:18 AMTask run '<id>' received abort during orchestration: This run cannot transition to the RUNNING state from the RUNNING state. Task run is in RUNNING state.
prefect.exceptions.MissingResult: State data is missing. Typically, this occurs when result persistence is disabled and the state has been retrieved from the API.
I’m getting this error. I have a Dask cluster on EKS. When I run the prefect flow locally, it connects to the dask cluster and runs it just fine. When I deploy it to the cloud, my prefect agent on Fargate runs the first task in my DAG and then crashes with this error a few seconds later. I’m using Prefect 2.8.0.Alex Turek
02/13/2023, 6:29 PMStéphan Taljaard
02/13/2023, 8:24 PMData Ops
02/14/2023, 2:13 PMJoseph Thickpenny Ryan
02/14/2023, 4:22 PMSidharth Ramalingam
02/15/2023, 3:36 PMJai P
02/15/2023, 4:01 PMJoseph Thickpenny Ryan
02/15/2023, 4:08 PMNikhil Jain
02/15/2023, 8:31 PMLate
or Pending
state for over 10 minutes, but we are seeing this even if the flow completed successfully and in less than 10 minutes.
Prefect flow Late or Pending for over 10 minutes
Flow run build-meta/spectral-anteater entered stateat 2023-02-15T193953.508606+00:00.Completed
Flow run URL: https://app.prefect.cloud/account/adee12e2-25d9-428a-9a77-32d8d7ca2ac7/workspace/28562586-0812-4e92-803f-99ce64384cbd/flow-runs/flow-run/81433951-84a0-4bb1-95e9-22a942912d3a
State message: All states completed.
Thet Naing
02/16/2023, 1:43 AMmap
for tasks. Is there a way to simplify the visualization so that it doesn't show every single task mapping on the UI? It also makes it rather difficult to see and understand what's happening in the flowjpuris
02/16/2023, 9:06 AMName: {{ work_queue.name }}
Last polled: {{ work_queue.last_polled }}
Late run count: {{ work_queue.late_runs_count }}
URL: {{ work_queue|ui_url }}
But.. why are all but 2 notifications with no values? (see screenshot below).
The two valid notifications are
1. The first one at 21:53 CEST
2. At 22:54 CEST (visible in screenshot)
edit: For the record.. We do not intend to run such trigger condition (it was a mis-configuration). We do not really care being notified every 10 seconds about a queue being healthy 😅 Hence the subject of the notifications in screenshot is mis-leading