Method create_job

src/codegraphcontext/core/jobs.py:75–86

Creates a new job, assigns it a unique ID, and stores it.

(self, path: str, is_dependency: bool = False)

        self.lock = threading.Lock() # A lock to ensure thread-safe access to the jobs dictionary.

    def create_job(self, path: str, is_dependency: bool = False) -> str:
        """Creates a new job, assigns it a unique ID, and stores it."""
        job_id = str(uuid.uuid4())
        with self.lock:
            self.jobs[job_id] = JobInfo(
                job_id=job_id,
                status=JobStatus.PENDING,
                start_time=datetime.now(),
                path=path,
                is_dependency=is_dependency
            )
        return job_id

    def update_job(self, job_id: str, **kwargs):
        """Updates the information for a specific job in a thread-safe manner."""