Permalink
Commits on Aug 18, 2017
  1. Inspect scheduler class settings in celery beat command. (#4189)

    * Inspect scheduler class settings in celery beat command.
    
    * Add myself to contributors list.
    Kxrr committed with thedrow Aug 18, 2017
  2. Adding ability to retry signal receiver after raised exception (#4192)

    daviddavis committed with thedrow Aug 18, 2017
  3. Allow to have a custom request (#3977)

    * Allow custom Request, aka custom `on_timeout`.
    
    Allowing a custom Request eases the task of handling timeouts (even hard
    timeouts).
    
    Rationale
    
    Some (poorly written) bits of code catch exceptions quite broadly:
    
      try:
          ...
      except:
          ...
    
    This hurts tasks when a SoftTimeLimitError is raised inside such blocks of
    code.  Rewriting those smelly bits of code can take a lot of effort, and
    sometimes, the code belongs to a third-party library which makes the task even
    harder.
    
    Using a custom request allows to catch hard time limits.
    
    Your app can be customized like:
    
       from celery import Task as BaseTask
       from celery.worker.request import Request as BaseRequest
    
       class Request(BaseRequest):
           def on_timeout(self, soft, timeout):
              super(Request, self).on_timeout(soft, timeout)
              if not soft:
    	     print('Something hard hit me!')
    
        class MyTask(BaseTask):
            Request = Request
    
        @app.task(base=MyTask, bind=True)
        def sometask(self):
            pass
    
    * Check signatures' types have a default Request.
    
    * Test Request is customizable per Task class.
    
    * Document custom requests.
    
    * Exemplify the usage of the custom requests.
    mvaled committed with thedrow Aug 18, 2017
Commits on Aug 17, 2017
  1. doc: adding examples to connect to sentinel broker (#4143)

    Signed-off-by: Geoffrey Bauduin <geoffrey.bauduin@corp.ovh.com>
    geoffreybauduin committed with auvipy Aug 17, 2017
  2. Django fixup should close all cache backends (#4187)

    raphael-riel committed with auvipy Aug 17, 2017
  3. Update CONTRIBUTORS.txt (#4210)

    * Update CONTRIBUTORS.txt
    
    Added name as requested
    
    * Update CONTRIBUTORS.txt
    
    Added missing comma
    diemuzi committed with auvipy Aug 17, 2017
  4. Update platforms.py (#4203)

    Rewords root user message to include the correct syntax on running as a different user
    diemuzi committed with thedrow Aug 17, 2017
  5. Update routing.rst (#4206)

    Typo fix.
    kanemra committed with thedrow Aug 17, 2017
Commits on Aug 16, 2017
  1. Adds stopasgroup to the supervisor scripts (#4200)

    * Adds stopasgroup to the supervisor scripts
    
    * Add details on the stopasgroup parameter in supervisor configs
    martialp committed with georgepsarakis Aug 16, 2017
Commits on Aug 10, 2017
  1. Update contributors file (#4190)

    Nicolas Mota committed with thedrow Aug 10, 2017
  2. Fix grammar, PEP8 (#4188)

    Nicolas Mota committed with thedrow Aug 10, 2017
Commits on Aug 8, 2017
  1. Using Exception.args to serialize/deserialize exceptions instead of s…

    …tr(Exception) (#4085)
    
    * Using Exception.args for serializetion
    
    * backwards compat
    
    * Fixed exception creating
    
    * Fixed typo
    
    * Test fix
    
    * backwards fixes
    
    * Formatting
    
    * Formatting and exception_to_python fix
    
    * Tests fix
    
    * Fixed exception deserialization
    
    * formatting
    frostoov committed with thedrow Aug 8, 2017
Commits on Jul 28, 2017
  1. Correct calculation of application current time with timezone (#4173)

    * Use datetime.astimezone to adjust current time
    
    * Remove import statements from Celery.now
    georgepsarakis committed on GitHub Jul 28, 2017
Commits on Jul 27, 2017
  1. Set the SO_REUSEADDR option on the socket (#3969)

    If the server exits before the client does, the port will appear to be in use for 90 seconds unless you set this option. TCP is annoying.
    tbodt committed with thedrow Jul 27, 2017
  2. Fix celery ignores exceptions raised during `django.setup()` (#4146)

    * Check `import_modules.send`’s return value in `import_default_modules`, make sure no exception is silenced.
    
    * Fix codestyle issues.
    kevingu1003 committed with thedrow Jul 27, 2017
  3. Broker connection uses the heartbeat setting from app config unless s…

    …et otherwise (#4148)
    
    * broker connection uses the heartbeat setting from app config unless set otherwise
    
    * test for broker heartbeat settings
    
    * split long lines of code
    mperice committed with thedrow Jul 27, 2017
Commits on Jul 26, 2017
  1. Fixed exception caused by next_transit receiving an unexpected argume…

    …nt. (#4103)
    
    * Fixed exception caused by next_transit receiving an unexpected argument.
    
    * Fixing inconsistent style.
    
    * Adding tests for solar methods to determine if they accept the use_center argument or not.
    
    * Fixing flake8 errors.
    DDevine committed with auvipy Jul 26, 2017
  2. Fix a couple typos (#4156)

    ryanguest committed with auvipy Jul 26, 2017
Commits on Jul 25, 2017
  1. Add options for exponential backoff with task autoretry (#4101)

    * Add options for exponential backoff with task autoretry
    
    * Add test for exponential backoff
    
    * closer to a fixed test
    
    * Move autoretry backoff functionality inside run wrapper
    
    * Add a test for jitter
    
    * Correct for semantics of `random.randrange()`
    
    `random.randrange()` treats the argument it receives as just *outside* the
    bound of possible return values. For example, if you call
    `random.randrange(2)`, you might get 0 or 1, but you'll never get 2.
    Since we want to allow the `retry_jitter` parameter to occasionally apply no
    jitter at all, we need to add one to the value we pass to `randrange()`,
    so that there's a chance that we receive that original value back.
    
    * Put side_effect on patch lines
    
    * Fix flake8
    
    * Add celery.utils.time.get_exponential_backoff_interval
    
    * Use exponential backoff calculation from utils in task
    
    * Update docs around retry_jitter
    
    * Remove unnecessary random.choice patching
    
    * Update task auto-retry documentation
    
    * PEP8: remove unused import
    
    * PEP8: remove trailing whitespace
    
    * PEP8: Fix E123 warning
    singingwolfboy committed with georgepsarakis Jul 25, 2017
  2. Update Celery/Python/Pypy versions in the README (#4157)

    - Celery bumped 4.1;
    - Python 3.6 now supported;
    - Pypy bumped to 5.8, which is used for CI.
    samueldg committed with auvipy Jul 25, 2017
Commits on Jul 24, 2017
  1. Bump version: 4.0.2 → 4.1.0

    thedrow committed Jul 24, 2017
  2. Changelog for version 4.1.0 (#4151)

    * Move 4.0 changelog to history, draft changelog 4.1.0
    
    * Categorize entries and summarize documentation contributors
    
    * Refine changelog entries
    
    * Finalize categorization and editing of changes
    
    * Update filename
    georgepsarakis committed with auvipy Jul 24, 2017
Commits on Jul 18, 2017
  1. Updating contributors list (#4141)

    pkmoore committed with auvipy Jul 18, 2017
  2. Fix typos (#4140)

    * examples/django: fix typo. iself => itself
    
    * examples/django: fix grammer.
    vivekanand1101 committed with auvipy Jul 18, 2017
  3. CELERY_SEND_EVENTS instead of CELERYD_SEND_EVENTS for 3.1.x compatibi…

    …lity (#3997)
    
    Use 3.1.x option CELERY_SEND_EVENTS in celery 4.0 instead of CELERYD_SEND_EVENTS for compatibility.
    celery 3.1.x : https://github.com/celery/celery/blob/v3.1.18/celery/app/defaults.py#L150
    anilaratna2 committed with auvipy Jul 18, 2017
  4. Restore behavior so Broadcast queues work. (#3934)

    * Restore behavior so Broadcast queues work.
    
    * Add unit test.
    
    * Add additional unit tests.
    clokep committed with auvipy Jul 18, 2017
  5. Make appstr use standard format (#4134) (#4139)

    pkmoore committed with auvipy Jul 18, 2017
  6. Resolve pip UnicodeEncoderError for PyPy environments (#4138)

    * Upgrade pip for PyPy environments
    
    * Specify version in pip upgrade
    
    * Suppress progress bar
    georgepsarakis committed with auvipy Jul 18, 2017
Commits on Jul 17, 2017
  1. Handle possibility there are no workers (#4074)

    Fixes issue where an exception is raised if eg `celery graph workers` is invoked when there are no workers at all.
    donkopotamus committed with auvipy Jul 17, 2017
Commits on Jul 16, 2017
  1. Make id, name always accessible from logging.Formatter via extra (#3994)

    * Make id, name always accessible from Formatter via extra
    
    * define info with docstring
    
    * use the same name to minimize the change
    * clarify the reason for passing 'extra'
    
    * Specific version for pydocstyle
    
    * Add myself to the contributors list
    yoichi committed with thedrow Jul 16, 2017
  2. Add worker_shutting_down signal (#3998)

    dhuang committed with auvipy Jul 16, 2017
Commits on Jul 15, 2017
  1. Bump PyPy version in build to 5.8.0 (#4128)

    * Bump PyPy to 5.8.0.
    
    * Test with PyPy 5.3.1 as well.
    
    * Fix bash script.
    
    * Minor corrections in Travis CI PyPy section
    
    * Detect PyPy environment
    
    * Fix Bash string matching for PyPy environment
    
    * Use sudo when running apt
    thedrow committed on GitHub Jul 15, 2017
Commits on Jul 14, 2017
  1. Update rdb.py (#4135)

    http://snippets.dzone.com/posts/show/7248 not available or on archive.org
    h4ck3rm1k3 committed with auvipy Jul 14, 2017
Commits on Jul 12, 2017
  1. Updated documentation settings for DatabaseScheduler. #4057 (#4058)

    rh0dium committed with auvipy Jul 12, 2017