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

Hiya prefect folks!

I have the following composition test for a flow that totally works. This composition test literally perfectly describes the flow in question:

``````

Hi <@U02RNHATVS9>, could you move the code to the thread to clear up the main channel a bit when you get the chance? I think with is because the Flow object creates copies of the task. Let me test this a bit and get back to you

```from prefect.core.edge import Edge

from src.flows.prereview_engagement_feature_store_flow import *

print(flow.tasks)
assert get_last_executed_value in flow.tasks
assert update_last_executed_value in flow.tasks
assert extract_from_snowflake in flow.tasks
assert dataframe_to_feature_group in flow.tasks
assert len(flow.tasks) == 4

...```
However it fails at the very first assertion. I have printed flow.tasks and I see as follows.

```{&lt;Task: get_last_executed_value&gt;, &lt;Task: extract_from_snowflake&gt;, &lt;Task: update_last_executed_value&gt;, &lt;Task: dataframe_to_feature_group&gt;}```


When I print out get_last_executed_value I get:

```&lt;Task: get_last_executed_value&gt;```

So if you have a flow:
```from prefect import Flow, task

@task
def abc(x):
    return x+1

@task
def bcd(x):
    return x

with Flow("..") as flow:
    a = abc(1)
    b = bcd(a)```

The test would be:
```from testing import *

assert a in flow```

Because a copy is create with the Functional API

So <@U01QEJ9PP53>, are you saying to ad that line, or replace some line with that line?

And where does `testing` come from? Because when I do that line it is telling me that's not a thing :disappointed:

Sorry, `testing.py` is the name of the file of my first file. So I am importing the Flow object and tasks from it

I am saying you need to assign your task copies to a variable, and then assert on that variable because it’s a copy

Hm. <@U01QEJ9PP53> I believe that that is what I am doing here: `from src.flows.prereview_engagement_feature_store_flow import *`

The assert on my example is on `a`, the copy of the task, not `abc()`, the task definition