Chris Hart
04/02/2020, 7:02 PMwith Flow("trainer", schedule=None) as flow:
rand = Parameter("rand", default=params["rand"])
limit = Parameter("limit", default=params["limit"])
class_type = Parameter("class_type", default=params["class_type"])
# tasks
training_data = fetch_training_data(rand, limit, class_type)
test_data = fetch_test_data(rand, limit, class_type)
trained_model = train_model(training_data)
test_model(trained_model, test_data)
flow_state = flow.run(executor=DaskExecutor(), parameters=params)
Scott Zelenka
04/02/2020, 7:03 PMScott Zelenka
04/02/2020, 7:03 PMChris Hart
04/02/2020, 7:04 PMChris Hart
04/02/2020, 7:04 PM