old_contents: """
  .. module:: operators.prepare_pipeline_operator
      :synopsis: Operator that prepares the pipeline
  
  .. moduleauthor:: Ludovic Claude <ludovic.claude@chuv.ch>
  """
  
  from airflow.operators import BaseOperator
  from airflow.utils import apply_defaults
  
  
  class PreparePipelineOperator(BaseOperator):
      """
      Prepare the pipeline by injecting additional information as XCOM messages.
  
      :param initial_root_folder: root folder for the initial folder containing the scans to
          process organised by folder and where the name of the folder is the session_id
      :type initial_root_folder: string
      """
  
      template_fields = ()
      template_ext = ()
      ui_color = '#243147'
  
      @apply_defaults
      def __init__(
              self,
              initial_root_folder,
              *args, **kwargs):
          super(EmailOperator, self).__init__(*args, **kwargs)
          self.initial_root_folder = initial_root_folder
  
      def execute(self, context):
          dr = context['dag_run']
          session_id = dr.conf['session_id']
          folder = self.initial_root_folder + '/' + session_id
  
          logging.info('folder %s, session_id %s' % (folder, session_id))
  
          xcom_push(key='folder', value=folder)
          xcom_push(key='session_id', value=session_id)
  
new_contents: """
  .. module:: operators.prepare_pipeline_operator
      :synopsis: Operator that prepares the pipeline
  
  .. moduleauthor:: Ludovic Claude <ludovic.claude@chuv.ch>
  """
  
  from airflow.operators import BaseOperator
  from airflow.utils import apply_defaults
  
  
  class PreparePipelineOperator(BaseOperator):
      """
      Prepare the pipeline by injecting additional information as XCOM messages.
  
      :param initial_root_folder: root folder for the initial folder containing the scans to
          process organised by folder and where the name of the folder is the session_id
      :type initial_root_folder: string
      """
  
      template_fields = ()
      template_ext = ()
      ui_color = '#243147'
  
      @apply_defaults
      def __init__(
              self,
              initial_root_folder,
              *args, **kwargs):
          super(PreparePipelineOperator, self).__init__(*args, **kwargs)
          self.initial_root_folder = initial_root_folder
  
      def execute(self, context):
          dr = context['dag_run']
          session_id = dr.conf['session_id']
          folder = self.initial_root_folder + '/' + session_id
  
          logging.info('folder %s, session_id %s' % (folder, session_id))
  
          xcom_push(key='folder', value=folder)
          xcom_push(key='session_id', value=session_id)
  
subject: Fix inheritance