Chris Comeau
05/10/2023, 10:01 PMdefs = Definitions(
assets=load_assets_from_modules(...),
executor=multiprocess_executor.configured(
config_or_config_fn={
"start_method": {"forkserver": {}},
"max_concurrent": 8,
}
),
)
This might be a good one to add to concurrency examples once it's in the new pythonic config style - I found it was really helpful to apply a kind of default run-level concurrency at the code location level, which then kicks in for jobs and ad-hoc runs. Nice and simple.