gistfile1.py

    def add_job(self, job_type, job_id=None, on_duplicate='overwrite',
                timestamp=None, distribute=None, **data):
        """
        Add a new job to execute

        :param job_type: string with the name of the job
        :param job_id: job identifier, if not set, then a new random unique id
                       will be generated
        :param on_duplicate: action on identifier duplicate, can be "overwrite"
                             or "discard"
        :param timestamp: None, datetime object, timedelta, or number of seconds
                          in which the job has to be executed
        :param distribute: distribute task among multiple handlers
            the parameter should look like `(seed_id, num_of_workers)`
        :param \*\*data: job data: kwargs for job handler function
        :return: job id as a string or None, if the queue is eager
        """