Maria
01/31/2024, 2:15 AMMarvin
01/31/2024, 2:15 AM.submit() method to queue up tasks within a flow, enabling one task to trigger the execution of another. Here's a simplified example from the documentation:
python
from prefect import flow, task
@task
def say_hello(name):
print(f"Hello {name}")
@task
def say_goodbye(name):
print(f"Goodbye {name}")
@flow
def greetings(names):
for name in names:
say_hello.submit(name)
say_goodbye.submit(name)
if __name__ == "__main__":
greetings(["arthur", "trillian", "ford", "marvin"])
In this code snippet, the greetings flow triggers the say_hello and say_goodbye tasks for each provided name. Tasks are submitted for execution with the submit method inside the flow definition.
You can find more detailed information and examples in the Prefect documentation.Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
Powered by