def __init__(self, task_obj):
        self.task_id = task_obj.task_id

        if self.unique.value == 0:
            with self.unique.get_lock():
                if self.unique.value == 0:
                    self.unique.value = os.getpid()  # The PID will be unique for every execution of the pipeline

        # Deleting old files > temp_time
        if os.path.isdir(self.temp_dir):
            import shutil
            import time
            limit = time.time() - self.temp_time
            for fn in os.listdir(self.temp_dir):
                path = os.path.join(self.temp_dir, fn)
                if os.path.isdir(path) and limit < os.stat(path).st_mtime:
                    shutil.rmtree(path)
                    logger.debug('Deleted temporary directory %s', path)
dataset/ETHPy150Open spotify/luigi/luigi/contrib/simulate.py/RunAnywayTarget.__init__/swapped operands of `<`