def conditionally_trigger(context, dag_run_obj):
    """
    This function decides whether or not to Trigger the remote DAG
    """

    params = context['params']['condition_param']

    # Look for the condition to trigger the DAG inside the context
    # parameters
    if context['params']['condition_param']:
        dag_run_obj.payload = {'message': context['params']['message']}
        print(dag_run_obj.payload)

        return dag_run_obj
    return None