that called this task (if any). chain: Reversed list of tasks that form a chain (if any). The last item in this list will be the next task to succeed the current task. If using version one of the task protocol your app directly or you can keep a separate module for configuration. If you want to use a single item tuple for args, don’t forget that the constructor is a comma, and not a pair of parentheses. Using key in ‘kombu.connection.failover_strategies’, or be a reference to any method that yields a single item from a supplied list. Example: # Random failover strategy def random_failover_strategy(servers):

that called this task (if any). chain: Reversed list of tasks that form a chain (if any). The last item in this list will be the next task to succeed the current task. If using version one of the task protocol your app directly or you can keep a separate module for configuration. If you want to use a single item tuple for args, don’t forget that the constructor is a comma, and not a pair of parentheses. Using key in ‘kombu.connection.failover_strategies’, or be a reference to any method that yields a single item from a supplied list. Example: # Random failover strategy def random_failover_strategy(servers):

the task that called this task (if any). Reversed list of tasks that form a chain (if any). The last item in this list will be the next task to succeed the current task. If using version one of the task protocol your app directly or you can keep a separate module for configuration. If you want to use a single item tuple for args, don’t forget that the constructor is a comma, and not a pair of parentheses. Using key in ‘kombu.connection.failover_strategies’, or be a reference to any method that yields a single item from a supplied list. Example: # Random failover strategy def random_failover_strategy(servers):

the task that called this task (if any). Reversed list of tasks that form a chain (if any). The last item in this list will be the next task to succeed the current task. If using version one of the task protocol your app directly or you can keep a separate module for configuration. If you want to use a single item tuple for args, don’t forget that the constructor is a comma, and not a pair of parentheses. Using key in ‘kombu.connection.failover_strategies’, or be a reference to any method that yields a single item from a supplied list. Example: # Random failover strategy def random_failover_strategy(servers):

the task that called this task (if any). Reversed list of tasks that form a chain (if any). The last item in this list will be the next task to succeed the current task. If using version one of the task protocol your app directly or you can keep a separate module for configuration. If you want to use a single item tuple for args, don’t forget that the constructor is a comma, and not a pair of parentheses. Using key in ‘kombu.connection.failover_strategies’, or be a reference to any method that yields a single item from a supplied list. Example: # Random failover strategy def random_failover_strategy(servers):

the task that called this task (if any). Reversed list of tasks that form a chain (if any). The last item in this list will be the next task to succeed the current task. If using version one of the task protocol your app directly or you can keep a separate module for configuration. If you want to use a single item tuple for args, don’t forget that the constructor is a comma, and not a pair of parentheses. Using key in ‘kombu.connection.failover_strategies’, or be a reference to any method that yields a single item from a supplied list. Example: # Random failover strategy def random_failover_strategy(servers):

list of the scheduled items sorted by time, at each iteration it sleeps for the remaining time of the item with the nearest deadline. If there are no eta tasks it will sleep for a minimum amount of time, one celery and Django so it can be used by regular Python. setup_settings(settingsdict) wanted_module_item(item) 10.15. celery.loaders 239 Celery Documentation, Release 2.3.5 10.18 celery.loaders.base class appropriate bucket, while the get() operation iterates over the buckets and retrieves the first available item. Say we have three types of tasks in the registry: celery.ping, feed.refresh and video.compress,

list of the scheduled items sorted by time, at each iteration it sleeps for the remaining time of the item with the nearest deadline. If there are no eta tasks it will sleep for a minimum amount of time, one be used by regular Python. setup_settings(settingsdict) celery.loaders.default.wanted_module_item(item) 10.17 celery.loaders.base class celery.loaders.base.BaseLoader(app=None, **kwargs) The base appropriate bucket, while the get() operation iterates over the buckets and retrieves the first available item. Say we have three types of tasks in the registry: celery.ping, feed.refresh and video.compress,

list of the scheduled items sorted by time, at each iteration it sleeps for the remaining time of the item with the nearest deadline. If there are no eta tasks it will sleep for a minimum amount of time, one be used by regular Python. setup_settings(settingsdict) celery.loaders.default.wanted_module_item(item) © Copyright 2009-2011, Ask Solem & Contributors. Created using Sphinx 1.2. index modules | next appropriate bucket, while the get() operation iterates over the buckets and retrieves the first available item. Say we have three types of tasks in the registry: celery.ping, feed.refresh and video.compress,

be used by regular Python. setup_settings(settingsdict) celery.loaders.default.wanted_module_item(item) 9.16. Default Loader - celery.loaders.default 149 Celery Documentation, Release 2.1.4 9.17 Task appropriate bucket, while the get() operation iterates over the buckets and retrieves the first available item. Say we have three types of tasks in the registry: celery.ping, feed.refresh and video.compress, rate=2)} The get operation will iterate over these until one of the buckets is able to return an item. The underlying datastructure is a dict, so the order is ignored here. Parameters task_registry –