st dabu

    st dabu

    1 year ago
    I am doing this python prefect_pipeline.py (this creates a flow and registers() and runs() it. when I do this , i only see that the prefect task is only registered in the prefect UI but actually not running in the agent but just in my local machine from where I invoke the python prefect_pipeline.py code..
    Bruno Murino

    Bruno Murino

    1 year ago
    Did you specify the agent when building the flow? Did you deploy the agent and the flow with the same labels? (not required for local agent)
    st dabu

    st dabu

    1 year ago
    "Did you specify the agent when building the flow?" I didnt do this..
    can you share that specific syntax ?
    Kevin Kho

    Kevin Kho

    1 year ago
    It sounds like you are using both
    flow.run()
    and
    flow.register()
    in the same script? You just need register and then Prefect Cloud will take care of triggering the flow runs based on the specified schedule or if you hit “Quick Run” on the Flow. These will then triggers Flow runs that can be picked up by agents.
    st dabu

    st dabu

    1 year ago
    Yeah, now in script , i just do flow.register and later i do
    prefect run -n hello-flow
    This works though
    Thanks @Bruno Murino @Kevin Kho