Brooke Talcott
04/26/2022, 12:34 AMfrom dagster import op, job, repository,Field
@op(config_schema={'example_config':str,'other_config':Field(str,default_value=None)})
def example_op():
...
def retreives_config_from_somewhere_else():
#oops someone forgot to specify 'other_config'
return {'ops':{'example_op':{'config':{'example_config':'test'}}}}
@job(config=retreives_config_from_somewhere_else())
def example_job():
example_op()
@repository
def example_repo():
return [example_job]
below fails to load the entire repository location, which is not great if we’re trying to manage a lot of similar but configurable jobs in the same repository. if someone fails to specify something, I’d rather it not block out the whole repo in dagit
from dagster import op, job, repository
@op(config_schema={'example_config':str,'other_config':str})
def example_op():
...
def retreives_config_from_somewhere_else():
#oops someone forgot to specify 'other_config'
return {'ops':{'example_op':{'config':{'example_config':'test'}}}}
@job(config=retreives_config_from_somewhere_else())
def example_job():
example_op()
@repository
def example_repo():
return [example_job]
this of course loads fine, but does not allow partial configuration
from dagster import op, job, repository
@op(config_schema={'example_config':str,'other_config':str})
def example_op():
...
@job
def example_job():
example_op()
@repository
def example_repo():
return [example_job]
prha
05/02/2022, 4:52 PMchris
05/02/2022, 4:55 PMBrooke Talcott
05/02/2022, 4:56 PM