def __init__(self, config, topology, task_to_component, my_task_id, metrics_collector, topo_pex_path):
    self.config = config
    self.topology = topology
    self.task_to_component_map = task_to_component
    self.task_id = my_task_id
    self.metrics_collector = metrics_collector
    self.topology_pex_path = os.path.abspath(topo_pex_path)
    (inputs, outputs, out_fields) = self._get_inputs_and_outputs_and_outfields(topology)
    self.inputs = inputs
    self.outputs = outputs
    self.component_to_out_fields = out_fields
    self.task_hooks = []
    self._init_task_hooks()
def __init__(self, config, topology, task_to_component, my_task_id, metrics_collector, topo_pex_path):
    self.config = config
    self.topology = topology
    self.task_to_component_map = task_to_component
    self.task_id = my_task_id
    self.metrics_collector = metrics_collector
    self.topology_pex_path = os.path.abspath(topo_pex_path)
    (inputs, outputs, out_fields) = self._get_inputs_and_outputs_and_outfields(topology)
    self.inputs = inputs
    self.outputs = outputs
    self.component_to_out_fields = out_fields
    self.task_hooks = []
    self._init_task_hooks()