code: def get_pipeline_and_notification_id(self, sequence_id, position):
          
          # Todo: Optimise query by selecting only two columns, pipeline_id and id (notification ID)?
          record = self.get_record(sequence_id, position)
          notification_id = getattr(record, self.notification_id_name)
          return record.pipeline_id, notification_id
docs: Returns pipeline ID and notification ID for
          event at given position in given sequence.