flowcraft/generator/inspect.py
def _clear_inspect(self):
        """Clears inspect attributes when re-executing a pipeline"""

        self.trace_info = defaultdict(list)
        self.process_tags = {}
        self.process_stats = {}
        self.samples = []
        self.stored_ids = []
        self.stored_log_ids = []
        self.time_start = None
        self.time_stop = None
        self.execution_command = None
        self.nextflow_version = None
        self.abort_cause = None
        self._c = 0
        # Clean up of tag running status
        for p in self.processes.values():
            p["barrier"] = "W"
            for i in ["submitted", "finished", "failed", "retry"]:
                p[i] = set()
def _clear_inspect(self):
        """Clears inspect attributes when re-executing a pipeline"""

        self.trace_info = defaultdict(list)
        self.process_tags = {}
        self.process_stats = {}
        self.samples = []
        self.stored_ids = []
        self.stored_log_ids = []
        self.time_start = None
        self.time_stop = None
        self.execution_command = None
        self.nextflow_version = None
        self.abort_cause = None
        self._c = 0
        # Clean up of tag running status
        for p in self.processes.values():
            p["barrier"] = "W"
            for i in ["submitted", "finished", "failed", "retry"]:
                p[i] = set()
def _clear_inspect ( self ) : self . trace_info = defaultdict ( list ) self . process_tags = { } self . process_stats = { } self . samples = [ ] self . stored_ids = [ ] self . stored_log_ids = [ ] self . time_start = None self . time_stop = None self . execution_command = None self . nextflow_version = None self . abort_cause = None self . _c = 0 # Clean up of tag running status for p in self . processes . values ( ) : p [ "barrier" ] = "W" for i in [ "submitted" , "finished" , "failed" , "retry" ] : p [ i ] = set ( )
Clears inspect attributes when re-executing a pipeline
Clears inspect attributes when re - executing a pipeline