All, I want to delete 200+ flow run that are in pending state, I can filter them in UI. However, I am not able to 'select all' and delete all at once. I have to select one check box at a time. Any short cut ?

Hi 🙂 Does prefect 2.0 export some metrics through an open-telemetry exporter for example ? 🙂 And more globally what is the best way to be alerted when a job fails ? (I have already an alert in my kubernetes cluster if a pod fails but maybe it’s possible to have something more prefect related/high level)

I observed that the pods start and keep failing and restarting While no resources show up when we get pods for default namespace

Hi everyone, This may seem a bit strange but I’m planning to use a Google Sheet as a front end where users can type in inputs. Then, users can click the submit button to trigger a Prefect flow that will read the Gsheet’s inputs, transform it, then write it back onto the Gsheet. I’m wondering if anyone has tried something similar and can offer feedback on my approach: 1. We have a button in Gsheets that will activate a Google Apps Script to do an API call 2. The API call (hosted on AWS API Gateway) will trigger a Lambda function, which will trigger a Prefect flow 3. Prefect flow will read data in Gsheets, transform the data, then write data in Gsheets Any suggestions or input is appreciated!

In one of my flows, I have a task to upload a video to s3 (boto3 s3 resource

upload_file()

call, because big&binary). Since it's synchronous, I can trust the file will be where desired when task succeeds. Next task in this flow is to transcode this video. I do so by creating a

mediaconvert

boto3

client, and sending a mess of json to its

create_job(**args)

method. This returns me... the job. Now from what I've read... I should be able to use a prefect built-in

prefect.tasks.aws.client_waiter.AWSClientWait

to wait for said job to finish (which is fine, at this point the workflow is serial/synchronous). Problem is... even when the job reports success (in the console, even!), it takes a while (minutes?!) for the transcoded movie to be present in the target bucket. I would then... need to enter another wait task until I could find the file in the bucket's list of objects, possibly through prefect.tasks.aws.s3.S3List? until I could proceed to do further things to this transcoded video? This conjunction sounds all too common not to have an integrated solution, unless I'm being dense (hah! no news there!) and not spotting an obvious solution. Any guidance?

Hey all! I am working on to integrate splunk with prefect agent. I need to know where all the LOGS being written, what is the path for the log files? Can anyone help?

@Marvin how do you specify pool size when creating a sqlalchemy connection block?

Hello: I am seeing a message > Work queue does not have any actively polling workers ready to execute work. But can find no documentation on this. Can someone assist?

@Marvin, how can I define a task with a specific timeout and retries?

hey guys, is there a way to use .map() and .submit() in asyncronous tasks in prefect 3? i'm trying to upgrade from version 2 but all my flows are async and anytime i try to await a mapped task i get this error: TypeError: object PrefectFutureList can't be used in 'await' expression