Hi <#CM28LL405|> <#C048ZHT5U3U|>, Got Runtime error as task runner is already started in below scena...

Anjaneyulu K

11/08/2022, 10:30 PM

Hi #CM28LL405 #C048ZHT5U3U, Got Runtime error as task runner is already started in below scenario

Copy code

@flow(name="Status check")
def run():
    a= "hello"
    if(condition):
        success
    else:
        run()

if __name__ == "__main__":
   run()

Can anyone help. This is more like recursive funtion

James Sopkin

11/08/2022, 10:37 PM

Couldn’t you achieve this with a while loop? What would be the reason to recursively call a flow?

Anjaneyulu K

11/08/2022, 10:42 PM

Copy code

@flow(name="Status check")
def run():
    a= task1 output

    if(task1 output condition):
        running other task2
    else:
       wait(10)
        run()

Anjaneyulu K

11/08/2022, 10:42 PM

this is exact sudo code

Anjaneyulu K

11/08/2022, 10:51 PM

I am checking status in time manner

Anjaneyulu K

11/08/2022, 11:44 PM

@James Sopkin Cant use recursive

Anjaneyulu K

11/08/2022, 11:44 PM

James Sopkin

11/08/2022, 11:50 PM

I don't believe it is possible to recursively call a flow. Could you try something like this?

Copy code

@flow(name="Status check")
def run():
  a = task1()
  while a != condition:
     a = task1()
     wait(10)
  task2()

Anjaneyulu K

11/08/2022, 11:57 PM

I did the same . but it is repeated code. I think even I cant use nested task

James Sopkin

11/09/2022, 2:31 PM

Could you post the logs? I tried doing something similar and it works fine

4 Views

Open in Slack

Previous Next

Prefect Community

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.