Missing required parameter

family

task_definition_name

taskDefinition

Failed to load and execute Flow's environment: InvalidParameterException('An error occurred (InvalidParameterException) when calling the RunTask operation: Task definition does not support launch_type FARGATE.')

Task definition does not support launch_type FARGATE

requiresCompatibilities

launch_type

requiresCompatibilities

boto3.register_task_definition

run_task

def get_aws_credentials() -> tuple:
    """
    Retrieve the AWS_ACCESS_KEY_ID and AWS_SECRET_ACCESS_KEY and return as a tuple
    :return: tuple of AWS_ACCESS_KEY_ID, AWS_SECRET_ACCESS_KEY
    """
    home = os.path.expanduser("~")
    creds_path = os.path.join(home, '.aws/credentials')
    if not os.path.isfile(creds_path):
        raise ValueError(f'You must have a configured ~/.aws/credentials file - see '
                         f'<https://docs.aws.amazon.com/cli/latest/userguide/cli-configure-files.html>')
    config = configparser.ConfigParser()
    try:
        config.read(creds_path)
    except Exception as ex:
        logger.warning(f'Unable to read {creds_path}, are permissions correct?')
        raise ex
    return config['default'].get('aws_access_key_id'), config['default'].get('aws_secret_access_key')


def set_aws_credentials_env():
    key_id, key = get_aws_credentials()
    os.environ['AWS_ACCESS_KEY_ID'] = key_id
    os.environ['AWS_SECRET_ACCESS_KEY'] = key
    os.environ['REGION_NAME'] = DEFAULT_REGION

TOKEN=`curl -s -X PUT "<http://169.254.169.254/latest/api/token>" -H "X-aws-ec2-metadata-token-ttl-seconds: 21600"`
EC2_IP=`curl -s -H "X-aws-ec2-metadata-token: $TOKEN" <http://169.254.169.254/latest/meta-data/local-ipv4>`

launchType=FARGATE

def __init__(  # type: ignore
    self,
    launch_type: str = "FARGATE",
    aws_access_key_id: str = None,
    aws_secret_access_key: str = None,
    aws_session_token: str = None,
    region_name: str = None,
    executor: "prefect.engine.executors.Executor" = None,
    executor_kwargs: dict = None,
    labels: List[str] = None,
    on_start: Callable = None,
    on_exit: Callable = None,
    metadata: dict = None,
    **kwargs,
) -> None:
    self.launch_type = launch_type
    # Not serialized, only stored on the object
    self.aws_access_key_id = aws_access_key_id or os.getenv("AWS_ACCESS_KEY_ID")
    self.aws_secret_access_key = aws_secret_access_key or os.getenv(
        "AWS_SECRET_ACCESS_KEY"
    )
    self.aws_session_token = aws_session_token or os.getenv("AWS_SESSION_TOKEN")
    self.region_name = region_name or os.getenv("REGION_NAME")