Method create

api_app/queryset.py:258–279

Creates a job, setting it as a child of the specified parent if provided. Args: parent (optional): The parent job, if any. **kwargs: The fields to set on the created job. Returns: The created job.

(self, parent=None, **kwargs)

    """

    def create(self, parent=None, **kwargs):
        """
        Creates a job, setting it as a child of the specified parent if provided.

        Args:
            parent (optional): The parent job, if any.
            **kwargs: The fields to set on the created job.

        Returns:
            The created job.
        """
        if parent:
            return parent.add_child(**kwargs)
        # try multiple times hoping to for no race conditions
        total_attempt_number = 5
        for attempt in range(0, total_attempt_number):
            try:
                return self.model.add_root(**kwargs)
            except IntegrityError:
                logger.warning(f"Found race condition for {kwargs['name']}. Trying again to calculate path.")
                if attempt == total_attempt_number - 1:
                    raise

    def delete(self, *args, **kwargs):
        """