Frank Shen
04/05/2023, 5:33 PMYee
@dynamic
def train_foreach_tenure(df, ...)
...
training_task(df=data).with_overrides(name=f"train-tenure-{tenure}")
Frank Shen
04/05/2023, 6:02 PMreturn object.__getattribute__(self, name)
AttributeError: 'DataFrame' object has no attribute 'with_overrides'
Yee
Frank Shen
04/05/2023, 6:18 PMSamhita Alla
with_overrides
on a simple task and see if that works?Frank Shen
04/07/2023, 11:54 PMSamhita Alla
@dynamic
def dynamic_wf():
t1(x=x).with_overrides(name="Hello-hello")
Frank Shen
04/10/2023, 5:05 PM@workflow
def wf_train_parallel():
for tenure in range(1, 25, 1):
xgbse_training(
tenure=tenure,
df=df
).with_overrides(name=f"xgbse_training_{tenure}")
karthikraj
04/10/2023, 5:22 PMrepository: pingsutw/flytepropeller
tag: fcfce5e490382297e88e8f8c5ca02084acf6a4d8
Samhita Alla
with_overrides
is working in a dynamic workflow but not in a workflow.
cc @Eduardo Apolinario (eapolinario)Frank Shen
04/11/2023, 4:07 PMSamhita Alla
Frank Shen
04/14/2023, 3:39 PMSamhita Alla
Frank Shen
04/14/2023, 4:37 PMflytekitplugins-snowflake==1.2.4
flytekitplugins-spark==1.2.4
Samhita Alla