def _set_dep()

in src/pydolphinscheduler/tasks/switch.py [0:0]

• 6 lines of code
• 3 McCabe index (conditional complexity)

    def _set_dep(self) -> None:
        """Set downstream according to parameter `condition`."""
        downstream = []
        for condition in self.condition.args:
            if isinstance(condition, SwitchBranch):
                downstream.append(condition.task)
        self.set_downstream(downstream)