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.

Prefect Community

any ideas, hints, suggestions, links to articles that could be of any help?

Hi <@U01HB6KRTPY>! Check out: <https://docs.prefect.io/core/idioms/flow-to-flow.html|https://docs.prefect.io/core/idioms/flow-to-flow.html>

Also, we :heart:threads here, helps keep the main channel readable

Let me know if you have any further questions :marvin: 

<@UKVFX6N3B> thanks, I did find the article, but still couldn’t apply it to my use case. i do have the StartFlowRun and later the `with Flow('parent-flow') as flow` setting the upstreams

the comment says: “assumes you have registered the following flows”. isn’t it what I’m doing when I say `customer_flow = Flow('customer_flow')`?

You need to create the flow and tasks and then call ‘flow.register()’

<https://docs.prefect.io/orchestration/concepts/flows.html#registration|https://docs.prefect.io/orchestration/concepts/flows.html#registration>

hm.. but even if i move the registration below everything, still get the same error (I do have the tasks refined above this code block)

maybe I’m not setting `dependencies` in the context of the imperative api maybe they are required?

Screen Shot 2020-12-24 at 17.27.28.png

the imperative api example:

```from prefect import Task, Flow

# The tasks
class RunMeFirst(Task):
    def run(self):
        print("I'm running first!")

class PlusOneTask(Task):
    def run(self, x):
        return x + 1

# Instanciates the Flow
flow = Flow('My Imperative Flow')

# The task instance (I'm using the decorator format), this is where I get the error
plus_one = PlusOneTask()

# I don't have that.
flow.set_dependencies(
    task=plus_one,
    upstream_tasks=[RunMeFirst()],
    keyword_tasks=dict(x=10))

flow.visualize()```

I’m not sure if those case statements are being set correctly with the imperative api

I think the context manager is only available within a flow context block

```with Flow("my flow") as flow:
  result = my_task()
  with case(result, True):
    #do something```

i think i got that from the docs but let me double check. the error appear in my second line (check_status task), do you think that the case statements must be interfering? 

I’m not as familiar with the imperative api

fair enough, let me try to adapt to the functional

You’ll need to register the parent as well

yes yes yes, I realized I was making a stupid mistake, lol

cool, seems to work with the functional approach. thanks a lot mate!

i’ll keep digging around, currently building a POC for an integration we have with about 10-15 different ERP systems that have to run every 1-5 minutes with different query for each system and each client. is been a nightmare to manage it trhough procedures and linked servers, no visibility on the health of the system whatsoever. airflow didn’t do the trick, NiFi is a bit outdated and not very nice to work when you have tons of flows, so Prefect seems perfect for the job, happy to have found it!

Glad to hear it!! And welcome to the community :prefect-duck:

thanks a lot! happy hollydays and thank you very much for your help, best!