Sridhar
09/28/2021, 9:33 AMfrom prefect.agent.ecs.agent import ECSAgent
AGENT = ECSAgent(cluster="prefect-fargate-cluster", labels=['ecs', 'dev'])
AGENT.start()
flow.py code:
import prefect
from prefect.storage import Docker
from prefect.run_configs import ECSRun
from prefect import task, Flow, Parameter
STORAGE = Docker(registry_url='<http://037961805145.dkr.ecr.ap-southeast-2.amazonaws.com/|037961805145.dkr.ecr.ap-southeast-2.amazonaws.com/>',
image_name='prefect-etl-flow',
image_tag='latest',
dockerfile='Dockerfile.txt')
RUN_CONFIG = ECSRun(run_task_kwargs={'cluster': 'prefect-fargate-cluster'},
execution_role_arn='arn:aws:iam::037961805145:role/prefect-ecs',
labels=['ecs', 'dev'])
@task
def testfunc():
print("Hello prefect!")
with Flow('prefect-etl-flow', storage=STORAGE, run_config=RUN_CONFIG) as flow:
testfunc()
flow.register('emmi-etl')
Really appreciate the help. Thanks in advance.Kevin Kho
Sridhar
09/30/2021, 12:47 AMKevin Kho
Kevin Kho