Sets the main raw inputs and secondary inputs on the init process This method will fetch the :class:`flowcraft.process.Init` process instance and sets the raw input ( :func:`flowcraft.process.Init.set_raw_inputs`) for that process. This will handle the connection of
(self)
| 809 | "\tChannels set for {} \u2713".format(p.template))) |
| 810 | |
| 811 | def _set_init_process(self): |
| 812 | """Sets the main raw inputs and secondary inputs on the init process |
| 813 | |
| 814 | This method will fetch the :class:`flowcraft.process.Init` process |
| 815 | instance and sets the raw input ( |
| 816 | :func:`flowcraft.process.Init.set_raw_inputs`) for |
| 817 | that process. This will handle the connection of the user parameters |
| 818 | with channels that are then consumed in the pipeline. |
| 819 | """ |
| 820 | |
| 821 | logger.debug("========================") |
| 822 | logger.debug("Setting secondary inputs") |
| 823 | logger.debug("========================") |
| 824 | |
| 825 | # Get init process |
| 826 | init_process = self.processes[0] |
| 827 | logger.debug("Setting main raw inputs: " |
| 828 | "{}".format(self.main_raw_inputs)) |
| 829 | init_process.set_raw_inputs(self.main_raw_inputs) |
| 830 | logger.debug("Setting extra inputs: {}".format(self.extra_inputs)) |
| 831 | init_process.set_extra_inputs(self.extra_inputs) |
| 832 | |
| 833 | def _set_secondary_channels(self): |
| 834 | """Sets the secondary channels for the pipeline |