cuddly-family-48123
02/28/2023, 4:57 AMpip install metaflow-netflixext --upgrade
to use the v2 @conda decorator.
Setting up task environment.
Downloading code package...
Code package downloaded.
Task is starting.
Bootstrapping environment...
Environment bootstrapped.
/bin/bash: line 1: metaflow_MinimumFlow_linux-64_c5b6dc01d4f4a08e54fef899876a247da78dfef5/bin/python: No such file or directory
Running:
python minimum_flow.py --environment=conda --with retry argo-workflows create
python minimum_flow.py --environment=conda --with retry argo-workflows trigger
Pretty simple:
from metaflow import FlowSpec, step, project, conda_base, environment
@project(name='minflow')
@conda_base(python="3.10.9",libraries={"pandas": "1.4.4", "python-duckdb": "0.6.1"})
class MinimumFlow(FlowSpec):
@step
def start(self):
self.next(self.end)
@step
def end(self):
print("Flow is done!")
if __name__ == "__main__":
MinimumFlow()