19db3e8350cefa14a282073c6837ef1b5263f309,reframe/frontend/executors/policies.py,AsynchronousExecutionPolicy,_remove_from_running,#AsynchronousExecutionPolicy#Any#,229

Before Change

        self.task_listeners.append(self)

    def _remove_from_running(self, task):
        getlogger().debug(
            "removing task from running list: %s" % task.check.info()
        )
        try:
            partname = task.check.current_partition.fullname
            self._running_tasks[partname].remove(task)
        except (ValueError, AttributeError, KeyError):

After Change

        self.task_listeners.append(self)

    def _remove_from_running(self, task):
        getlogger().debug2(
            f"Removing task from the running list: {task.testcase}"
        )
        try:
            partname = task.check.current_partition.fullname
            self._running_tasks[partname].remove(task)
        except (ValueError, AttributeError, KeyError):

Instances