Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(48)  |  Call(24)  |  Derive(0)  |  Import(24)

src/c/e/celery-3.1.11/examples/resultgraph/tasks.py   celery(Download)
 
 
from celery import chord, group, task, signature, uuid
from celery.result import AsyncResult, ResultSet, allow_join_result
from collections import deque

src/c/e/celery-HEAD/examples/resultgraph/tasks.py   celery(Download)
 
 
from celery import chord, group, task, signature, uuid
from celery.result import AsyncResult, ResultSet, allow_join_result
from collections import deque

src/c/e/celery-HEAD/celery/app/builtins.py   celery(Download)
def add_chord_task(app):
    """No longer used, but here for backwards compatibility."""
    from celery import group, chord as _chord
    from celery.canvas import maybe_signature
    _app = app
            ], app=self.app)
            body = maybe_signature(body, app=app)
            ch = _chord(header, body)
            return ch.run(header, body, partial_args, app, interval,
                          countdown, max_retries, propagate, **kwargs)

src/z/a/zamboni-HEAD/apps/addons/management/commands/process_addons.py   zamboni(Download)
from django.db.models import Q
 
from celery import chord, group
 
import amo
            if 'post' in task:
                post = task['post'].subtask(args=[], kwargs=kw, immutable=True)
                ts = chord(grouping, post)
            else:
                ts = group(grouping)

src/g/u/gunnery-HEAD/gunnery/backend/tasks.py   gunnery(Download)
from paramiko import AuthenticationException
from time import sleep
from celery import group, chain, chord, Task
from django.conf import settings
from django.utils.timezone import now
            tasks = [CommandTask().si(execution_command_server_id=server.id) for server in command.servers.all()]
            if len(tasks):
                chord_chain.append(chord(tasks, _dummy_callback.s()))
        chord_chain.append(ExecutionTaskFinish().si(execution_id))
        chain(chord_chain)()

src/z/a/zamboni-HEAD/mkt/webapps/cron.py   zamboni(Download)
import commonware.log
import cronjobs
from celery import chord
 
import amo
 
    post = zip_users.subtask(immutable=True)
    ts = chord(grouping, post)
    ts.apply_async()
 

src/c/e/celery-pipelines-0.1.0/pipelines/models.py   celery-pipelines(Download)
from celery import Task, group, chain, chord
from celery import current_app
from celery.contrib.methods import task_method
 
from collections import OrderedDict

src/d/j/django-ngrams-0.1.24/ngrams/tasks.py   django-ngrams(Download)
import os
import re
 
from celery import task,chord,group,chain
from celery.signals import task_success

src/d/j/django-celex-lexicon-0.1.94/celex/tasks.py   django-celex-lexicon(Download)
import cPickle as pickle
 
from celery import task,chord,group,chain
from celery.signals import task_success
from celery.utils.log import get_task_logger

src/d/j/django-buckeye-corpus-0.3.55/buckeyebrowser/tasks.py   django-buckeye-corpus(Download)
import math
 
from celery import task,chord,group
from celery.signals import task_success
from celery.utils.log import get_task_logger

  1 | 2  Next