Skip to content
Snippets Groups Projects
Select Git revision
  • 0f8ef4220c559985e95795521404c657cb2fe1e2
  • development default protected
  • 3.2.x-stable
  • prepare
  • 6b369dc5
  • 3.1.x-stable
  • 3.0.x-stable
  • 2.4.x-stable
  • v3.2.61
  • v3.2.60
  • v3.2.59
  • v3.2.54
  • v3.2.53
  • v3.2.52
  • v3.2.51
  • v3.2.48
  • v3.2.45
  • v3.2.44.3
  • v3.2.44
  • v3.2.40
  • v3.2.13
  • v3.2.9
  • v3.2.8
  • v3.2.7
  • v3.2.6
  • v3.2.5
  • v3.2.4
  • v3.2.3
28 results

main.py

Blame
  • Code owners
    Assign users and groups as approvers for specific file changes. Learn more.
    job_controller.py 502 B
    from event_queue import EventQueue
    from job_api import JobData, JobDatabaseApi
    from jobs.dummy_job import DummyJob
    from kubernetes_api import K8sApi
    
    
    class ControllerState():
    
        def __init__(self) -> None:
            self.k8s = K8sApi()
            self.job_api = JobDatabaseApi()
            self.event_queue = EventQueue()
    
        def wrap_job(self, job: JobData) -> "WrappedJob":
            if job.job_type == "dummy":
                return DummyJob(job)
            raise Exception(f"Unknown job type: {job.job_type}")