code: def _UpdateForemanProcessStatus(self):
      used_memory = self._process_information.GetUsedMemory() or 0
      display_name = getattr(self._merge_task, 'identifier', '')
      self._processing_status.UpdateForemanStatus(
          self._name, self._status, self._pid, used_memory, display_name,
          self._number_of_consumed_sources, self._number_of_produced_sources,
          self._number_of_consumed_events, self._number_of_produced_events,
          self._number_of_consumed_event_tags,
          self._number_of_produced_event_tags,
          self._number_of_consumed_warnings, self._number_of_produced_warnings,
          self._number_of_consumed_reports, self._number_of_produced_reports)
      self._processing_status.UpdateEventsStatus(self._events_status)