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)