
PIPELINE_XCOMS = ['folder', 'session_id', 'participant_id', 'scan_date', 'spm_output', 'spm_error', 'dataset']

def pipeline_trigger(parent_task):
    """
      Use this function with TriggerDagRunOperator to always trigger a DAG and
      pass pipeline information to the next DAG
    """

    def trigger(context, dag_run_obj):
        """
          Use this function with TriggerDagRunOperator to always trigger a DAG and
          pass pipeline information to the next DAG
        """
        ti = context['task_instance']
        dr = context['dag_run']
        dag_run_obj.payload = {}
        for key in PIPELINE_XCOMS:
            dag_run_obj.payload[key] = ti.xcom_pull(task_ids=parent_task, key=key)
            if (not dag_run_obj.payload[key]) and key in dr.conf:
                dag_run_obj.payload[key] = dr.conf[key]
        return dag_run_obj

    return trigger

class TransferPipelineXComs(Object):
    def __init__(parent_task):
        self.parent_task = parent_task
        self.pipeline_xcoms = {}

    def read_pipeline_xcoms(context):
        for xcom in PIPELINE_XCOMS:
            value = self.xcom_pull(context, task_ids=self.parent_task, key=xcom)
            if value:
                self.pipeline_xcoms[xcom] = value

    def write_pipeline_xcoms(context):
        for key,value in self.pipeline_xcoms.items():
            self.xcom_push(context, key=key, value=value)

@@ -902,17 +902,17 @@
 neXComs(
-O
+o
 bject):%0A

Fix case