def _describe()

in custom-resource/dms_task_conf/task.py [0:0]


def _describe(replication_task_arn):
    try:
        describe_replication_tasks = client.describe_replication_tasks(
            Filters=[{"Name": "replication-task-arn", "Values": [replication_task_arn]}]
        )
        return describe_replication_tasks["ReplicationTasks"][0]["Status"]

    except ClientError as e:
        logger.error(e)