When launching a scheduled pipeline is the return from the repository fixed from the time you launch the scheduler? More specifically, if I want to do something like

@repository
def tmp_pipeline_repository():
    tmp_pipeline = pipeline_factory()
    return [tmp_pipeline, tmp_pipeline_schedule]

where

pipeline_factory

returns a pipeline whose functionality changes based on some external data which changes asynchronously from the pipeline, will the pipeline be reconstructed before each scheduled run? If not, is there a way to do this that conforms to

dagster

design patterns? Happy to clarify the details further if this is too vague

Hi Henry - the scheduler can pick up code changes without restarting. They should be picked up within a minute or so after the code is changed.

Perfect, thanks!