https://prefect.io
Join Slack
what’s the best way to call a task within a prefect flow (for integration tests)? ```flow.<method...
# prefect-server
l
what’s the best way to call a task within a prefect flow (for integration tests)?
Copy code
flow.<method name>(<method arguments>)
doesn’t work, so i assume we’d need to grab the task from 
flow.tasks
and then run the task object. so my follow up question would be, what is the best way to retrieve a task by name from a 
Flow
object?
k
Let me try it out
Have you seen this page though?
Like this maybe?
Copy code
from prefect import Flow, task

@task
def abc(x):
    return x

@task
def bcd(x):
    return x

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

print(flow.tasks)
print(list(flow.tasks)[0].name)
And then find the one with the name you want? But I think you can just test the task directly?
l
hmm, i know the name of the task i want to test but i don’t know how to test running that task specifically. i guess i can just import the task directly and run it? if you have
Copy code
@task
def abc(x):
    return x
and you import 
from myflow import abc
then is that a task object or just a method?
k
That is a task so you can do 
abc.run()
🙌 2
8 Views
Open in Slack
PreviousNext
Powered by

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.

Powered by