Nicholas
@flow(name='test') def my_flow( project_id: str, configuration: Configuration ) -> dict: ... class S3Bucket(BaseModel): name: str path: str class Configuration(BaseModel): input: S3Bucket output: S3Bucket force_overwrite: bool = False
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.