def create()

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)