Method enqueue

huey/api.py:298–326

(self, task)

        return self._registry.create_task(message)

    def enqueue(self, task):
        if isinstance(task, group):
            return ResultGroup([self.enqueue(t) for t in task.tasks])
        elif isinstance(task, chord):
            return self._enqueue_chord(task)

        # Resolve the expiration time when the task is enqueued.
        if task.expires:
            task.resolve_expires(self.utc)

        self._emit(S.SIGNAL_ENQUEUED, task)

        if self._immediate:
            self.execute(task)
        else:
            self.storage.enqueue(self.serialize_task(task), task.priority)

        if not self.results:
            return

        if task.on_complete:
            current = task
            results = []
            while current is not None:
                results.append(Result(self, current))
                current = current.on_complete
            return ResultGroup(results)
        else:
            return Result(self, task)

    def _enqueue_chord(self, chord_obj):
        cid = str(uuid.uuid4())