in custom-resource/dms_task_conf/task.py [0:0]
def create(event, context):
logger.info("Got Create")
properties = event.get("ResourceProperties", None)
replication_task_arn = properties.get("ReplicationTaskArn")
_create(replication_task_arn)