https://prefect.io
Join Slack
Hi folks, I believe we are facing an issue with manual_only triggered tasks. Mainly the task seems t...
# ask-community
m
Hi folks, I believe we are facing an issue with manual_only triggered tasks. Mainly the task seems to be nullifying the parameters passed to it
(We are running a DaskExecutor on EKS with prefect cloud ) A very simplified version of the flow …
Copy code
with Flow("test") as flow:
        date = get_date() # inspecting the logs date is not None

        run_task_manual_task(date=date) # date=None is used when the task is resumed
k
Hey @Marwan Sarieddine, was this working before?
m
first time I try it - will try to replicate it with a much simpler version of the flow and then provide an update
k
Is this a parameter or a regular task?
m
a regular task
k
Ah ok do you know if there is a result attached to it?
m
there must be given there are other tasks that made use of the 
date
result successfully
and I don’t see anywhere where these other tasks mutate 
date
(unless if I am missing something)
ah well - take it back I think we are talking about two different things I think you meant a prefect Result attached to the task - no I don’t have that - is that necessary for manual_only tasks ?
k
I’m not sure, but I think it could make sense why since the Flow might have to pick off from where it left off by fetching the upstream result. Yes I mean Prefect Result. Maybe you can give that function a PrefectResult for the Result to it gets persisted in our database?
m
yea I guess that would explain things …
yea so just to confirm this is what prefect cloud shows for that date task
Copy code
Result Type: Result
Result Location: None
ok so I will need to persist that result so it can be fetched when the manual task is resumed … - makes sense
(thanks @Kevin Kho)
k
Uhh I’m not sure yet lol. Just a guess. We’ll see
m
lol - true
will confirm soon hopefully
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