62e49f63c91997fd837ce94a5d069246bb8a6b69,app/grandchallenge/components/models.py,ComponentJob,schedule_job,#ComponentJob#,244

Before Change

    def schedule_job(self):

        kwargs = {}

        if self.container.requires_gpu:
            kwargs.update({"queue": "gpu"})

        if getattr(self.container, "queue_override", None):
            kwargs.update({"queue": self.container.queue_override})

        execute_job.apply_async(
            **kwargs,
            kwargs={
                "job_pk": self.pk,
                "job_app_label": self._meta.app_label,
                "job_model_name": self._meta.model_name,
            },
        )

    class Meta:
        abstract = True

After Change

        raise NotImplementedError

    def schedule_job(self):
        self.signature.apply_async()

    @property
    def signature(self):
        options = {}

Instances