def add_computation(self, map_task):
    computation_id = self.system_name_to_computation_id_map.get(
        map_task.systemName, map_task.systemName)
    if computation_id not in self.instruction_map:
      self.instruction_map[computation_id] = map_task
dataset/ETHPy150Open GoogleCloudPlatform/DataflowPythonSDK/google/cloud/dataflow/worker/streamingworker.py/StreamingWorker.add_computation/original