flowcraft/generator/report.py
def update_log_watch(self):
        """Parses nextflow log file and updates the run status
        """

        # Check the size stamp of the tracefile. Only proceed with the parsing
        # if it changed from the previous size.
        size_stamp = os.path.getsize(self.log_file)
        self.trace_retry = 0
        if size_stamp and size_stamp == self.log_sizestamp:
            return
        else:
            logger.debug("Updating log size stamp to: {}".format(size_stamp))
            self.log_sizestamp = size_stamp

        self._update_pipeline_status()
def update_log_watch(self):
        # Check the size stamp of the tracefile. Only proceed with the parsing
        # if it changed from the previous size.
        size_stamp = os.path.getsize(self.log_file)
        self.trace_retry = 0
        if size_stamp and size_stamp == self.log_sizestamp:
            return
        else:
            logger.debug("Updating log size stamp to: {}".format(size_stamp))
            self.log_sizestamp = size_stamp

        self._update_pipeline_status()
def update_log_watch ( self ) : # Check the size stamp of the tracefile. Only proceed with the parsing # if it changed from the previous size. size_stamp = os . path . getsize ( self . log_file ) self . trace_retry = 0 if size_stamp and size_stamp == self . log_sizestamp : return else : logger . debug ( "Updating log size stamp to: {}" . format ( size_stamp ) ) self . log_sizestamp = size_stamp self . _update_pipeline_status ( )
Parses nextflow log file and updates the run status
Parses nextflow log file and updates the run status