King Chung Huang
07/25/2019, 11:23 PMprefix
config to something like _foo_
as part of the pipeline, and still optionally set it via the environment when executing the pipeline?
@solid(
config={'prefix': Field(str, is_optional=True, default_value='_')}
)
def prefix_value(context, v):
return f'{context.solid_config["prefix"]}{v}'
@pipeline
def test_normalize():
prefix_value.alias('prefix_foo')() # set prefix to _foo_ somehow?
prefix_value.alias('prefix_bar')() # and, set prefix to _bar_ somehow?
schrockn
07/27/2019, 10:30 PM