9cde7c0f67be8c8c4aba71315d8875171d939992,src/python/pants/bin/local_pants_runner.py,LocalPantsRunner,_get_workunits_callbacks,#LocalPantsRunner#,238

Before Change

        // the new WorkunitsCallbackFactories method.
        // NB: When the `--streaming-workunits-handlers` deprecation triggers, the first method will be
        // removed.
        streaming_handlers = self.options.for_global_scope().streaming_workunits_handlers
        callbacks = list(Subsystem.get_streaming_workunit_callbacks(streaming_handlers))
        (workunits_callback_factories,) = self.graph_session.scheduler_session.product_request(
            WorkunitsCallbackFactories, [self.union_membership]
        )
        for wcf in workunits_callback_factories:
            callbacks.append(wcf.callback_factory())
        return tuple(callbacks)

    def run(self, start_time: float) -> ExitCode:
        run_tracker = RunTracker.global_instance(silent=True)
        self._start_run(run_tracker, start_time)

After Change

        (workunits_callback_factories,) = self.graph_session.scheduler_session.product_request(
            WorkunitsCallbackFactories, [self.union_membership]
        )
        return tuple(wcf.callback_factory() for wcf in workunits_callback_factories)

    def run(self, start_time: float) -> ExitCode:
        self._start_run(start_time)

Instances