Channels
#prefect-community
Title
v
vinoth paari
02/09/2022, 5:00 AMHi How to call outside flow from task. I am getting error
k
Kevin Kho
02/09/2022, 5:03 AM
Copy code
with Flow(..) as flow:
create_flow_run(...) Copy code
create_flow_run.run(...)v
vinoth paari
02/09/2022, 5:05 AMis it possible to call flow from task?
And Not working in while loop
k
Kevin Kho
02/09/2022, 5:07 AM
If you want to use a task in another task, you have to call the .run() method explicitly but it’s not treated as a task. It’s just the Python underneath that is invoked.
What are you trying to do with the infinite loop? I would not recommend that because you should just spin up an infinite number of flow runs. I would put the infinite loop inside a task inside if you want an indefinitely running Flow.
But it’s not a pattern Prefect specifically supports
v
vinoth paari
02/09/2022, 5:11 AMMy requirement is streaming data processing
Step :
I will configure the One flow which is continuosly listening my API . If my API gives any reponses . It will trigger another flow where i will do some operation .
Initiate the another flow continuously like parallel process
k
Kevin Kho
02/09/2022, 5:13 AM
What is your requirement for the latency? Because Prefect can’t really do this at below 1 minute level
v
vinoth paari
02/09/2022, 5:14 AMyes . thaty i using while loop for listing . my problem is unable to initiate another flow from task
k
Kevin Kho
02/09/2022, 5:15 AM
It’s primarily a batch orchestrator. Prefect 2.0 though will support this use case but it is still in technical preview
You can by calling
.run() Copy code
@task
def some_task():
create_flow_run.run(...)v
vinoth paari
02/09/2022, 5:16 AMso i missed .run right?
k
Kevin Kho
02/09/2022, 5:17 AM
In this example yes but just not it’s not a task anymore.
It wont get retries and state tracking
v
vinoth paari
02/09/2022, 5:18 AMyes it working now
2 Views