Hi Community - me again. I have a strange one, I have set up an agent in ECS with a custom image that has

prefect-aws

deps installed. I have an infrastructure

ECSTask

block that pulls a custom image:

FROM        prefecthq/prefect:2.6.5-python3.9

RUN         pip install prefect-aws s3fs==2022.5.0

This installs everything I need to run a demo flow that is:

import prefect
from prefect import flow, task, get_run_logger
from utilities import AN_IMPORTED_MESSAGE

from prefect_aws.ecs import ECSTask

ecs_task_block = ECSTask.load("staging-test")


@task
def log_task():
    logger = get_run_logger()
    <http://logger.info|logger.info>("Hello %s!", "BEN")
    <http://logger.info|logger.info>("Prefect Version = %s 🚀", prefect.__version__)
    logger.debug(AN_IMPORTED_MESSAGE)


@flow
def my_test_flow(name: str):
    log_task(name)


if __name__ == "__main__":
    my_test_flow()

This flow is using S3 Block Storage, now when I trigger this flow from the cloud UI the task is generated in my cluster, it just fails with a

ModuleNotFoundError: No module named 'prefect_aws.ecs'

More details in 🧵