This message was deleted.

try with

Path('some_tasks.yaml').write_text('')

to create an empty file. does that change the error message?

I tried that edit, but it seems I encounter the same error. I have attached the full stack trace

ah ok. I think it's because the DAGSpec is initialized from a dictionary. instead of a path to a file. add a new line before the

spec = DAGSpec(spec_d)

to store the contents of

spec_d

in a

pipeline.yaml

file, (using yaml.dump), then replace the

spec = DAGSpec(spec_d)

for

spec = DAGSpec('pipeline.yaml')

Would it be like this? When I run this again I get the same error

please push that to your fork. I'll take a look 🙂

just pushed it, thanks! sorry for all the trouble

no worries, thanks for the hard work!