How can we pause a task until a specified time and how to resume the same task before the timeout with some external triggers

[anna_geller]

I see. For event-driven workflows, check those resources:

Is there an equivalent to sensors in Prefect? How do I trigger event-driven workflows?

There are a couple of ways how you could approach that problem. 1. State-based execution with signals If you look more closely at what sensors are doing, they are polling for some state (e.g. whether a file arrived in S3/SFTP) and if the condition is not met, the sensor sleeps and tries again in a couple of seconds/minutes later. If you want to implement something similar in Prefect, you could leverage the RETRY signal to implement such polling. Here is an example checking if “example_file.c…

Easy Event-Driven Workflows With AWS Lambda V2 Featuring Serverless Framework - by George Coyne

This blog post explains how you can trigger a Prefect flow from AWS Lambda. The Lambda function itself gets deployed using the serverless framework. It also presents a compelling use case: the function gets triggered any time a new file arrives in a given S3 bucket, the function checks the file size of the S3 object, based on the file size of the S3 object, it allocates more or less memory on your Kubernetes flow run pod to make sure your execution environment has enough memory to process the…

It’s hard for me to help because you are still describing solutions, not the actual problem or use case. Could you describe it more from a business perspective? What is this task that may time out doing? And when should this event be triggered?

@gaurav_amoga could you perhaps show how would you approach it in plain Python?