future-monitor-58430
from flytekit import workflow, LaunchPlan, task from dataclasses import dataclass from dataclasses_json import dataclass_json @dataclass_json @dataclass class MyDataClass(object): def __init__(self, a: int, b: str): self.a = a self.b = b @task def example_node(input: MyDataClass): print(f'{input.a}') @workflow def my_dataclass_workflow(input: MyDataClass): return example_node(input=input)
broad-monitor-993
@dataclass_json @dataclass class MyDataClass(object): a: int b: str
Flyte enables production-grade orchestration for machine learning workflows and data processing created to accelerate local workflows to production.