Thomas Yopes
06/04/2021, 9:13 AMexecute_pipeline
from a solid in another pipeline? I've tried lots of different ways to get Dagster to run a schedule for a pipeline that needs to be re-generated fresh when the scheduler starts, but haven't been able to make any progress (lots of config, timing, and invariant errors -- tried sensors with no luck, assets, etc). For the time being, I'm simply going to have a helper pipeline that calls the code required to generate the dynamic pipeline then calls execute_pipeline
and it would be great if this dynamic pipeline appeared in the runs tab. Let me know! or let me know if you're someone who's managed to get Docker + Dagster working with dynamic pipeline generation (note: I don't mean the dynamic output but defining the entire pipeline up front before it's executed).matas
06/04/2021, 9:38 AMimport yaml
from dagster import execute_pipeline, reconstructable, DagsterInstance
from my_repo import my_pipeline
res = execute_pipeline(
reconstructable(my_pipeline),
mode='my_mode',
run_config=yaml.safe_load(open('my_config.yml')),
instance=DagsterInstance.get(),
)
Thomas Yopes
06/04/2021, 9:40 AMmatas
06/04/2021, 9:42 AMDagsterInstance.get()
Thomas Yopes
06/04/2021, 9:42 AMexecute_pipeline
thing wasn't option as there was no way to visualize -- but you have saved me 🙏 🙏alex
06/04/2021, 2:47 PMexecute_pipeline
? Im sure we could make it clearer there if we use the right phrasingThomas Yopes
06/04/2021, 5:32 PM