Search.setIndex({"docnames": ["admin", "architecture", "brokers", "chain", "cluster", "configure", "errors", "examples", "group", "index", "install", "iterable", "monitor", "schedules", "signals", "tasks"], "filenames": ["admin.rst", "architecture.rst", "brokers.rst", "chain.rst", "cluster.rst", "configure.rst", "errors.rst", "examples.rst", "group.rst", "index.rst", "install.rst", "iterable.rst", "monitor.rst", "schedules.rst", "signals.rst", "tasks.rst"], "titles": ["Admin pages", "Architecture", "Brokers", "Chains", "Cluster", "Configuration", "Errors", "Examples", "Groups", "Welcome to Django Q2", "Installation", "Iterable", "Monitor", "Schedules", "Signals", "Tasks"], "terms": {"django": [0, 1, 4, 5, 6, 7, 8, 12, 13, 14, 15], "q2": [0, 2, 4, 5, 6, 7, 14, 15], "doe": [0, 2, 4, 5, 10, 12, 13, 15], "us": [0, 1, 2, 3, 5, 6, 7, 8, 9, 10, 11, 12, 13, 15], "custom": [0, 5, 7, 9, 10], "instead": [0, 2, 3, 5, 7, 8, 11, 13, 15], "leverag": 0, "what": [0, 5, 7, 12, 13], "i": [0, 1, 2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15], "offer": [0, 8, 10], "": [0, 1, 2, 4, 5, 7, 8, 10, 12, 15], "model": [0, 7, 13, 15], "default": [0, 1, 2, 4, 5, 7, 8, 10, 13, 15], "when": [0, 1, 2, 3, 5, 6, 12, 13, 15], "you": [0, 1, 2, 3, 4, 5, 7, 8, 10, 11, 12, 13, 15], "open": [0, 2], "see": [0, 1, 2, 3, 4, 5, 6, 11, 12, 15], "three": 0, "show": [0, 2, 4, 7, 12], "all": [0, 1, 2, 4, 5, 7, 10, 11, 12, 15], "successfulli": 0, "execut": [0, 1, 2, 3, 5, 7, 11, 12, 13, 15], "mean": [0, 2, 5, 10, 12, 13, 15], "thei": [0, 4, 10, 11, 13], "did": 0, "encount": [0, 5, 6, 10], "ani": [0, 1, 2, 4, 5, 10, 12, 14, 15], "error": [0, 1, 5, 9, 10, 12, 15], "dure": [0, 10, 14], "from": [0, 1, 2, 3, 4, 5, 7, 8, 9, 11, 12, 13, 14, 15], "here": [0, 7], "can": [0, 1, 2, 3, 4, 5, 7, 8, 10, 11, 12, 13, 15], "look": [0, 7], "detail": [0, 5, 12, 15], "each": [0, 1, 4, 5, 8, 15], "delet": [0, 2, 7, 8, 13, 15], "them": [0, 1, 3, 5, 7, 8, 11, 12, 13, 15], "group": [0, 3, 5, 9, 13], "filter": [0, 8, 15], "your": [0, 2, 4, 5, 6, 7, 8, 10, 12, 13, 15], "result": [0, 1, 2, 3, 4, 5, 7, 8, 9, 10, 11, 12, 13, 14, 15], "name": [0, 1, 2, 3, 4, 9, 13, 14, 15], "id": [0, 2, 3, 4, 11, 13, 15], "The": [0, 1, 2, 4, 5, 7, 10, 11, 12, 13, 14, 15], "tabl": [0, 5, 10], "searchabl": 0, "func": [0, 3, 5, 11, 13, 14, 15], "proxi": [0, 15], "maximum": [0, 2, 5], "number": [0, 2, 3, 4, 5, 8, 10, 12, 13, 15], "set": [0, 1, 2, 4, 5, 6, 7, 8, 10, 11, 12, 13, 15], "save_limit": [0, 9], "option": [0, 1, 2, 3, 4, 5, 8, 11, 12, 13, 15], "have": [0, 1, 2, 4, 5, 7, 10, 11, 12, 15], "an": [0, 1, 2, 3, 4, 5, 6, 7, 10, 11, 12, 13, 15], "prevent": [0, 5], "finish": [0, 1, 3, 4, 5, 12, 15], "worker": [0, 2, 3, 4, 9, 10, 11, 12, 15], "try": [0, 7, 10], "put": [0, 1, 2, 5, 15], "field": [0, 7, 10], "so": [0, 2, 5, 7, 12], "review": 0, "happen": 0, "resubmit": 0, "back": [0, 1, 2, 5], "queue": [0, 1, 2, 3, 5, 7, 9, 10, 11, 12, 13, 15], "action": [0, 7, 15], "menu": 0, "failur": [0, 1, 2, 3, 5, 7, 8, 9, 15], "ui": 0, "creat": [0, 1, 3, 7, 10, 13, 14, 15], "own": [0, 1, 2, 15], "modeladmin": 0, "class": [0, 2, 3, 4, 5, 6, 7, 11, 12, 13, 15], "site": [0, 4, 5], "unregist": 0, "regist": [0, 6], "replac": [0, 13], "exampl": [0, 2, 4, 5, 6, 8, 9, 11, 13, 15], "django_q": [0, 1, 2, 3, 4, 5, 7, 8, 10, 11, 12, 13, 14, 15], "import": [0, 2, 3, 5, 7, 8, 11, 12, 13, 14, 15], "q_model": 0, "q_admin": 0, "childclassadmin": 0, "failadmin": 0, "list_displai": 0, "start": [0, 1, 3, 4, 5, 7, 9, 11, 12, 13, 15], "add": [0, 2, 3, 5, 7, 8, 9, 11, 12], "attempt_count": 0, "check": [0, 1, 4, 9, 12, 13, 15], "statu": [0, 2, 4, 7, 9, 13], "edit": [0, 2], "If": [0, 1, 2, 4, 5, 7, 10, 11, 12, 13, 14, 15], "want": [0, 2, 3, 5, 7, 8, 10, 12, 13, 15], "onli": [0, 1, 2, 4, 5, 7, 8, 10, 12, 13, 15], "finit": 0, "amount": [0, 1, 2, 5, 12, 15], "time": [0, 1, 2, 5, 7, 10, 12, 13, 15], "e": [0, 4, 5, 13, 15], "g": [0, 4, 5, 13, 15], "everi": [0, 7, 13], "hour": [0, 5, 7, 12, 13], "24": [0, 12, 13], "do": [0, 2, 4, 7, 10], "attribut": [0, 15], "In": [0, 1, 2, 5, 7, 13], "thi": [0, 1, 2, 3, 4, 5, 7, 8, 9, 10, 11, 12, 13, 14, 15], "case": [0, 1, 2, 4, 5, 13, 15], "would": 0, "type": [0, 2, 5, 7, 8, 11, 12, 13, 15], "hourli": [0, 13], "count": [0, 3, 5, 7, 8, 10, 11, 12, 13, 15], "down": [0, 5, 12, 13], "until": [0, 1, 3, 5, 8, 13, 15], "hit": [0, 12], "zero": [0, 1, 5], "longer": [0, 5, 10, 12], "1": [0, 1, 3, 4, 5, 7, 8, 9, 10, 11, 12, 13, 15], "continu": [0, 1, 13], "indefinit": [0, 8, 15], "still": [0, 1, 10, 12], "indic": [0, 1, 4, 5, 15], "how": [0, 2, 3, 5, 7, 11, 15], "mani": [0, 2, 3, 5, 8, 11, 15], "ha": [0, 1, 2, 4, 5, 7, 8, 9, 12, 13, 14, 15], "been": [0, 2, 4, 5, 12, 13, 15], "except": [0, 1, 5, 7, 10, 11, 12], "ar": [0, 1, 4, 5, 6, 7, 8, 10, 11, 12, 13, 15], "onc": [0, 1, 2, 5, 7, 10, 11, 13, 15], "neg": [0, 1, 13], "caus": [0, 5, 7], "databas": [0, 1, 2, 5, 7, 8, 9, 10, 11, 12, 13, 15], "behavior": [0, 2, 5, 13], "delai": [0, 7], "which": [0, 1, 4, 5, 6, 7, 10, 11, 12, 13], "necessarili": 0, "need": [0, 2, 5, 7, 10, 12, 13, 15], "A": [0, 1, 3, 4, 7, 12, 13, 15], "posit": [0, 13, 15], "keep": [0, 1, 2, 5, 8, 10, 12, 13, 15], "again": [0, 1, 5, 7, 13, 15], "paus": 0, "its": [0, 2, 5, 12, 13, 14, 15], "valu": [0, 1, 5, 15], "To": [0, 4, 5, 12, 13], "chang": [0, 5, 7, 13, 15], "someth": [0, 5, 7, 13], "other": [0, 4, 5, 7, 10, 13, 14, 15], "than": [0, 2, 5, 8, 10, 12], "0": [0, 3, 4, 5, 7, 8, 9, 10, 11, 12, 13, 15], "new": [0, 1, 2, 5, 6, 7, 9, 12, 15], "befor": [0, 1, 3, 5, 8], "let": [0, 7, 10, 15], "immedi": [0, 13, 15], "ad": [0, 5, 7, 8], "link": [0, 13], "noth": [0, 4], "hasn": [0, 15], "t": [0, 1, 2, 4, 5, 7, 8, 15], "yet": [0, 2, 15], "configur": [0, 1, 2, 4, 6, 9, 10, 12, 13, 15], "save": [0, 1, 2, 5, 7, 11, 12], "view": [0, 7], "enabl": [0, 5, 7, 15], "orm": [0, 9], "broker": [0, 3, 4, 5, 9, 10, 11, 12, 13], "It": [0, 1, 4, 5, 10, 12, 13, 14], "packag": [0, 1, 2, 5, 6, 9, 13, 15], "current": [0, 2, 3, 4, 5, 6, 9, 10, 11, 12, 15], "lock": 0, "column": 0, "moment": [0, 10, 13, 15], "wa": [0, 1, 5, 12, 13, 14, 15], "pick": [0, 1], "up": [0, 1, 2, 4, 5, 7, 8, 10, 11, 13, 15], "cluster": [0, 1, 2, 3, 5, 6, 7, 9, 10, 11, 12, 13, 15], "determin": [0, 4, 10, 13], "whether": 0, "expir": 0, "For": [0, 3, 5, 6, 7, 10, 12, 15], "develop": [0, 5, 6, 9, 10, 15], "purpos": 0, "first": [1, 2, 5, 13, 15], "pickl": 1, "core": [1, 7, 10, 13], "modul": [1, 4, 5, 7, 10, 13, 15], "secret_kei": [1, 4, 5], "salt": 1, "being": [1, 2, 10, 15], "sent": 1, "messag": [1, 2, 5, 7, 10], "ensur": [1, 4], "read": 1, "server": [1, 2, 5, 7, 10, 12], "who": 1, "share": [1, 4, 7, 12], "same": [1, 2, 3, 4, 5, 8, 11, 12, 13, 14, 15], "secret": 1, "kei": [1, 5, 10, 13], "fail": [1, 2, 3, 5, 7, 8, 9, 10, 15], "unpack": [1, 2], "mark": 1, "discard": [1, 2, 5], "compress": [1, 9], "transport": 1, "collect": 1, "instanc": [1, 2, 3, 4, 7, 8, 9, 11, 12, 13, 15], "support": [1, 2, 5, 9, 10], "receipt": [1, 2, 5], "copi": [1, 7], "around": [1, 15], "acknowledg": [1, 2, 5], "process": [1, 2, 5, 9, 10, 12, 15], "otherwis": [1, 5, 15], "after": [1, 2, 5, 7, 12, 13, 15], "period": 1, "least": [1, 2, 7, 10], "deliveri": [1, 2, 5], "most": [1, 2, 5, 10, 15], "crash": [1, 2, 4], "ack_failur": [1, 9], "fals": [1, 5, 7, 8, 12, 13, 15], "consid": [1, 2, 5], "rais": 1, "true": [1, 2, 3, 4, 5, 7, 8, 10, 12, 13, 15], "success": [1, 5, 7, 8, 9, 13, 15], "intern": [1, 2, 4, 10], "control": [1, 4, 15], "memori": [1, 5, 12], "usag": [1, 4, 5], "minim": 1, "data": 1, "loss": 1, "pull": [1, 7], "countdown": 1, "timer": [1, 2], "about": [1, 12], "work": [1, 2, 4, 5, 7, 9, 10, 12, 15], "tri": [1, 5, 15], "afterward": [1, 15], "reset": [1, 15], "includ": [1, 2, 3, 6, 8, 14, 15], "irrespect": 1, "step": 1, "push": [1, 4], "onto": 1, "both": [1, 2, 10, 15], "cach": [1, 2, 3, 7, 8, 9, 10, 11, 12], "backend": [1, 2, 3, 5, 7, 8, 10, 11, 12, 15], "part": [1, 15], "chain": [1, 9], "next": [1, 5, 13], "queu": [1, 5, 9, 14], "spawn": [1, 4, 5, 12], "health": [1, 4, 9], "sudden": [1, 5, 12], "death": [1, 12], "reincarn": [1, 4, 12], "signal": [1, 4, 9], "receiv": [1, 2, 7, 14], "halt": 1, "instruct": [1, 2, 4, 15], "remain": [1, 5], "item": [1, 5], "meanwhil": 1, "don": [1, 2, 5, 7, 15], "reach": [1, 2, 12], "termin": [1, 5, 10, 12], "one": [1, 2, 4, 5, 7, 10, 12, 15], "twice": [1, 2], "minut": [1, 12, 13], "should": [1, 2, 4, 5, 10, 12, 13], "subtract": 1, "repeat": [1, 5, 7, 9, 12, 13], "run": [1, 2, 3, 4, 5, 7, 8, 10, 11, 12, 13, 15], "left": 1, "exit": 1, "guard": [1, 4, 5], "loop": [1, 5], "confirm": 1, "poison": 1, "pill": 1, "wait": [1, 2, 3, 4, 5, 7, 8, 11, 15], "empti": [1, 2], "complet": [1, 5, 15], "send": [1, 2, 7, 15], "event": [1, 4, 13], "clear": [1, 7, 11, 12], "we": [1, 2, 4, 7, 10], "forc": [1, 5, 15], "lose": 1, "held": 1, "manag": [1, 7, 9, 10, 12, 15], "queue_limit": [1, 2, 4, 9, 12], "sit": 2, "between": [2, 5, 15], "accept": [2, 11, 13], "deliv": 2, "task": [2, 3, 4, 5, 7, 8, 9, 10, 11, 12, 13], "varieti": 2, "catastroph": 2, "timeout": [2, 3, 4, 7, 9, 12, 13], "were": 2, "get": [2, 3, 5, 7, 8, 10, 11, 12, 15], "lost": 2, "mind": [2, 5, 15], "code": [2, 5, 10, 12, 13, 15], "lead": [2, 5, 10], "even": [2, 5], "though": [2, 15], "might": [2, 5, 10, 13], "some": [2, 3, 5, 7, 10, 11, 12], "prefer": 2, "These": [2, 6, 7], "guarante": [2, 15], "retri": [2, 9, 15], "pointer": 2, "lower": 2, "equal": 2, "spend": [2, 5, 15], "high": [2, 5, 10, 12], "out": [2, 5, 12, 13, 15], "while": [2, 4, 5, 7, 13], "updat": [2, 7, 9], "latest": [2, 10], "rare": 2, "non": 2, "atom": 2, "re": [2, 5, 7], "previou": [2, 7], "succeed": 2, "limit": [2, 5, 8, 12], "handl": [2, 4, 5, 7, 10, 12, 13], "global": [2, 15], "actual": [2, 10, 14], "more": [2, 3, 5, 11, 12, 15], "requir": [2, 5, 7, 9], "py": [2, 4, 5, 6, 7, 10, 12, 13, 15], "client": [2, 10], "librari": [2, 5, 10], "pip": [2, 10], "instal": [2, 5, 9, 12, 13], "framework": [2, 5, 10, 12], "monitor": [2, 4, 5, 6, 9, 10, 14, 15], "exist": [2, 13], "django_redi": [2, 9], "connect": [2, 4, 5, 7, 9, 12, 13, 14], "compat": [2, 9, 10], "http": [2, 5, 9, 12], "base": [2, 5, 6, 7, 12, 13], "servic": [2, 6], "avail": [2, 5, 9, 10, 12, 13, 15], "directli": [2, 5, 7, 8, 13, 15], "via": [2, 4, 5, 6, 15], "iron": [2, 5, 10], "io": [2, 5], "heroku": [2, 4], "bulk": [2, 9], "dequeu": [2, 5], "mq": [2, 5, 10], "iron_mq": [2, 9], "section": 2, "simpl": [2, 15], "anoth": [2, 12], "although": 2, "fastest": 2, "stabl": 2, "cheap": 2, "conveni": [2, 3, 11, 15], "alreadi": [2, 5], "aw": [2, 5], "size": [2, 5, 10, 15], "256kb": [2, 5], "10": [2, 4, 5, 7, 8, 9, 10, 15], "total": [2, 5], "boto3": [2, 5, 10], "highli": [2, 10], "scalabl": [2, 10], "nosql": [2, 10], "make": [2, 5, 7, 10, 12, 13, 15], "veri": [2, 5, 10, 15], "fast": [2, 10], "reliabl": [2, 10], "persist": [2, 10, 15], "usual": [2, 10], "paa": [2, 9, 10], "provid": [2, 5, 10, 14], "sourc": 2, "commerci": 2, "enterpris": 2, "through": [2, 10, 13], "sever": [2, 9, 12], "pymongo": [2, 5, 10], "driver": 2, "mongo": [2, 9], "select": [2, 5], "unless": [2, 8], "dedic": 2, "probabl": [2, 7], "choic": 2, "traffic": [2, 5], "setup": [2, 7], "howev": [2, 5, 10, 13], "medium": 2, "rate": [2, 12], "schedul": [2, 4, 7, 9, 10], "admin": [2, 5, 7, 9, 13], "overrid": [2, 5, 15], "deriv": 2, "custombrok": [2, 5], "def": [2, 7, 13, 14, 15], "info": [2, 4, 5, 9, 10], "self": [2, 7], "return": [2, 3, 4, 5, 7, 8, 11, 12, 13, 15], "my": [2, 7, 15], "broker_class": [2, 9], "q_cluster": [2, 4, 5, 6], "8": [2, 5, 7, 9, 10], "60": [2, 5, 15], "myapp": [2, 5], "write": [2, 7], "pleas": [2, 5, 7, 10, 15], "contribut": 2, "project": [2, 5, 7, 9, 10, 12], "commun": 2, "differ": [2, 4, 5, 15], "async_task": [2, 3, 4, 5, 7, 8, 9, 11, 13], "track": 2, "list": [2, 3, 8, 11, 12, 15], "tupl": [2, 11, 15], "notifi": [2, 10], "tell": [2, 4, 7], "occur": [2, 15], "purge_queu": 2, "delete_queu": 2, "queue_siz": [2, 15], "lock_siz": 2, "method": [2, 5, 6], "await": 2, "implement": [2, 5, 6, 12], "ping": 2, "version": [2, 9, 10, 15], "get_brok": [2, 15], "sometim": [3, 7, 11], "sequenti": 3, "async_chain": 3, "function": [3, 5, 7, 8, 11, 13, 14, 15], "async": [3, 7, 10, 11, 15], "result_group": [3, 7, 8, 15], "must": [3, 5, 6], "format": [3, 8, 15], "arg": [3, 7, 10, 11, 13, 15], "kwarg": [3, 6, 7, 10, 11, 13, 14, 15], "group_id": [3, 8, 15], "math": [3, 8, 11, 13, 15], "copysign": [3, 11, 13, 15], "floor": [3, 8, 11, 15], "2": [3, 5, 7, 8, 9, 10, 11, 13, 15], "slightli": [3, 12], "wai": [3, 5, 10], "append": [3, 7, 11], "print": [3, 7, 8, 11, 12, 14, 15], "none": [3, 5, 8, 11, 12, 13, 15], "conf": [3, 4, 7, 11], "sync": [3, 9, 10, 11], "also": [3, 4, 5, 7, 8, 10, 11, 15], "paramet": [3, 5, 8, 11, 13, 15], "str": [3, 8, 11, 13, 15], "bool": [3, 4, 5, 8, 11, 15], "against": [3, 8, 10, 11, 15], "inlin": [3, 10, 11, 15], "asynchron": [3, 9, 11, 15], "act": 3, "wrapper": [3, 11, 13, 15], "pass": [3, 5, 6, 7, 8, 11, 12, 13, 15], "construct": [3, 11], "individu": [3, 5, 11, 15], "param": [3, 11, 15], "take": [3, 5, 7, 8, 12, 15], "argument": [3, 4, 7, 11, 13, 14, 15], "rtype": [3, 11], "int": [3, 8, 11, 13, 15], "full": [3, 11, 15], "block": [3, 5, 8, 15], "millisecond": [3, 8, 11, 15], "unsort": [3, 11], "fetch": [3, 8, 11, 15], "object": [3, 4, 7, 8, 10, 11, 12, 13, 15], "index": [3, 7, 9], "element": 3, "length": [3, 11], "python": [4, 5, 6, 7, 9, 12, 15], "multiprocess": [4, 5, 9, 10, 12], "pool": [4, 9], "command": [4, 7, 9, 10, 11, 12, 15], "qcluster": [4, 10, 15], "57": 4, "40": 4, "q": [4, 5, 6, 7, 9, 12, 13], "freddi": 4, "uncl": 4, "twenti": 4, "ten": 4, "ede257774c4444c980ab479f10947acc": 4, "readi": [4, 12], "31784": 4, "ed580482da3f42968230baa2e4253e42": 4, "31785": 4, "8a370dc2bc1d49aa9864e517c9895f74": 4, "31786": 4, "74912f9844264d1397c6e54476b530c0": 4, "31787": 4, "b00edb26c6074a6189e5696c60aeb35b": 4, "31788": 4, "b0862965db04479f9784a26639ee51e0": 4, "31789": 4, "7e8abbb8ca2d4d9bb20a937dd5e2872b": 4, "31790": 4, "31791": 4, "67fa9461ac034736a766cd813f617e62": 4, "31792": 4, "eac052c646b2459797cee98bdb84c85d": 4, "31783": 4, "5d98deb19b1e4b2da2ef1e5bd6824f75": 4, "31793": 4, "stop": [4, 7, 9, 12, 15], "ctrl": 4, "c": [4, 10, 13], "either": [4, 5, 12, 15], "sigterm": 4, "sigkil": 4, "initi": [4, 6], "procedur": [4, 9], "16": 4, "44": 4, "12": [4, 9, 10], "13": 4, "14": 4, "15": [4, 5], "recycl": [4, 9, 12], "cpu_affin": [4, 9], "machin": 4, "long": [4, 5, 12], "identifi": [4, 8, 13, 15], "altern": [4, 5, 7, 10, 15], "On": [4, 5], "linux": 4, "q_cluster_nam": 4, "window": [4, 7], "valid": [4, 7], "alt_clust": [4, 9], "keyword": [4, 5, 8, 11, 13, 15], "match": [4, 13], "host": [4, 5, 7], "honcho": 4, "entri": 4, "like": [4, 5, 7, 10, 12, 15], "certainli": 4, "supervisor": 4, "circu": 4, "strictli": 4, "necessari": [4, 5, 6], "sentinel": [4, 5, 9, 12], "accord": [4, 13], "unexpect": 4, "becaus": [4, 5, 7], "daemon": [4, 5], "natur": 4, "imposs": 4, "resourc": [4, 5, 12], "ini": 4, "check_delai": 4, "5": [4, 5, 7, 8, 9, 10, 13, 15], "endpoint": 4, "tcp": 4, "127": [4, 5], "5555": 4, "pubsub_endpoint": 4, "5556": 4, "stats_endpoint": 4, "5557": 4, "watcher": 4, "cmd": 4, "numprocess": 4, "copy_env": 4, "note": [4, 5, 7, 8, 15], "good": [4, 7, 10, 12], "idea": [4, 7], "environ": [4, 5, 7], "sinc": [4, 7, 9, 10, 12], "increas": 4, "perform": [4, 5, 10, 15], "likelihood": 4, "diminish": 4, "program": 4, "stopasgroup": 4, "singl": [4, 5, 6, 7, 10, 11, 12, 15], "doesn": [4, 8], "leav": 4, "orphan": [4, 5], "restart": 4, "stat": [4, 7, 12], "pid": [4, 12], "hostnam": [4, 7, 12], "contain": [4, 5, 7, 11, 15], "second": [4, 5, 7, 11, 12, 15], "start_ev": 4, "stop_ev": 4, "is_start": 4, "busi": 4, "is_run": 4, "is_stop": 4, "has_stop": 4, "dictionari": [5, 6, 14, 15], "myproject": 5, "500": [5, 7], "250": 5, "port": [5, 7, 10], "6379": 5, "db": [5, 7], "3000": 5, "3600": 5, "short": 5, "differenti": 5, "sign": [5, 9], "invalid": [5, 15], "signatur": 5, "cpu": [5, 10], "flag": 5, "mai": [5, 12, 13, 15], "disabl": [5, 12], "child": 5, "care": [5, 7, 8], "main": 5, "releas": [5, 10], "regular": [5, 7, 13], "basi": 5, "resid": 5, "kilobyt": 5, "platform": 5, "psutil": [5, 10], "allow": [5, 6, 7], "never": [5, 13], "sens": 5, "overridden": 5, "timezon": [5, 7], "issu": [5, 10], "dst": 5, "utc": 5, "calcul": [5, 7, 12, 15], "date": [5, 10, 13], "therefor": [5, 6], "ignor": [5, 11, 13], "move": [5, 7], "ahead": 5, "use_tz": 5, "unsuccess": 5, "therebi": 5, "remov": 5, "per": [5, 12], "attempt": 5, "infinit": 5, "present": [5, 12], "bigger": 5, "longest": 5, "less": [5, 13], "hold": 5, "follow": [5, 7, 10, 13, 14, 15], "4": [5, 8, 9, 10, 13], "sleep": 5, "22": [5, 13], "call": [5, 7, 8, 10, 13, 14, 15], "exceed": 5, "21": 5, "four": 5, "20": 5, "anymor": 5, "abov": 5, "shortli": 5, "could": [5, 7], "multipl": [5, 9], "larg": [5, 15], "payload": 5, "overhead": [5, 7], "small": 5, "unlimit": 5, "storag": 5, "alwai": [5, 10, 12, 13, 15], "fine": [5, 10], "tune": 5, "store": [5, 7, 10, 12, 15], "possibl": [5, 7, 10, 15], "greater": 5, "effect": 5, "everyth": [5, 12, 15], "synchron": [5, 9], "test": [5, 9, 10], "rather": 5, "kept": 5, "reason": [5, 12], "help": [5, 15], "balanc": 5, "workload": 5, "page": [5, 7, 13], "didn": 5, "plai": [5, 13], "catch": [5, 13], "miss": [5, 9], "slot": [5, 13], "thing": [5, 7], "those": [5, 7, 13], "normal": [5, 12], "resum": 5, "localhost": [5, 7], "password": 5, "socket_timeout": 5, "charset": 5, "utf": [5, 7], "strict": 5, "unix_socket_path": 5, "uri": 5, "h": [5, 7, 13], "asdfqwer1234asdf": 5, "ec2": 5, "111": 5, "comput": [5, 7], "amazonaw": 5, "com": [5, 7, 9], "inform": [5, 6, 7, 10, 12], "refer": [5, 7, 9, 10], "document": [5, 7], "advantag": [5, 15], "excel": 5, "suppli": [5, 15], "direct": 5, "djredi": 5, "90": 5, "crossov": 5, "sure": [5, 7, 12, 15], "ironmq": [5, 9, 10], "ironbrok": 5, "30": [5, 13, 15], "50": [5, 15], "u": [5, 7], "east": 5, "token": 5, "et1en7": 5, "0luw39q": 5, "project_id": 5, "500f7b": 5, "b0f302e9": 5, "amazon": [5, 9, 10], "region": 5, "credenti": 5, "config": [5, 12], "sqsexampl": 5, "100": [5, 7, 8, 11, 15], "aws_region": 5, "aws_access_key_id": 5, "ac": 5, "idr": 5, "ywflzbaaxi": 5, "aws_secret_access_kei": 5, "proper": 5, "access": [5, 8, 10, 12, 15], "djangorm": 5, "120": 5, "better": [5, 15], "migrat": [5, 9], "mongodb": [5, 9, 10], "simpli": [5, 10], "70": 5, "27017": 5, "expos": [5, 6], "mongocli": 5, "inherit": 5, "children": 5, "improv": 5, "especi": [5, 15], "latenc": 5, "benefit": [5, 8], "too": [5, 7, 8], "degrad": 5, "Not": 5, "interv": 5, "affect": [5, 8], "gather": [5, 13], "statist": [5, 10, 12, 13], "switch": 5, "retain": 5, "reduc": 5, "littl": 5, "temporarili": 5, "redirect": [5, 15], "variou": 5, "report": [5, 6, 9, 10], "rollbar": [5, 6, 9, 10], "sentri": [5, 6, 9, 10], "extra": [5, 6], "extens": 5, "access_token": 5, "32we33a92a5224jiww8982": 5, "plugin": [5, 6], "processor": 5, "auxiliari": 5, "tweak": 5, "affin": [5, 10], "higher": 5, "3": [5, 7, 8, 9, 10, 11, 13], "6": [5, 13], "7": 5, "load": [5, 10], "consist": 5, "experi": 5, "best": [5, 10], "As": [5, 15], "rule": 5, "thumb": 5, "favor": [5, 10], "repetit": 5, "o": [5, 7, 12, 13], "x": [5, 7, 9, 12], "dict": [5, 11, 13, 15], "cluster_nam": 5, "few": 5, "cours": [5, 7, 8], "root": [5, 7], "footnot": [5, 12], "cpu_count": [5, 10], "manual": [5, 15], "pluggabl": 6, "system": [6, 10], "upon": 6, "anyon": 6, "favorit": 6, "integr": [6, 9], "invok": 6, "particular": [6, 8, 13], "order": [6, 10], "instanti": [6, 15], "why": 7, "welcom": 7, "mail": 7, "datetim": [7, 13], "timedelta": 7, "util": [7, 10, 12], "welcome_mail": 7, "user": 7, "msg": 7, "our": 7, "websit": 7, "right": [7, 10], "awai": 7, "send_mail": 7, "tip": 7, "schedule_typ": [7, 13], "next_run": [7, 13], "now": [7, 10, 13], "eras": 7, "itself": [7, 15], "quickli": [7, 15], "serv": [7, 11], "web": 7, "place": [7, 10, 13], "creation": 7, "trigger": 7, "lot": [7, 15], "contrib": 7, "auth": 7, "pre_sav": 7, "dispatch": [7, 14], "sender": [7, 14], "email_chang": 7, "pk": 7, "doesnotexist": 7, "els": 7, "hi": 7, "everyon": 7, "inform_everyon": 7, "address": 7, "almost": 7, "exclud": [7, 8, 15], "f": [7, 14], "dear": 7, "usernam": 7, "send_mass_mail": 7, "inform_everyone_async": 7, "Of": [7, 12], "besid": 7, "just": [7, 12], "gener": [7, 13, 15], "sai": 7, "without": [7, 10, 15], "By": [7, 15], "attach": 7, "impact": 7, "request": 7, "hook": [7, 9, 11, 13], "create_report": 7, "create_html_report": 7, "email_report": 7, "html_report": 7, "had": [7, 12], "great": 7, "quarter": 7, "mailer": 7, "went": 7, "wrong": 7, "mail_admin": 7, "practic": [7, 13], "detach": 7, "search": 7, "engin": 7, "real": 7, "post_sav": 7, "post": 7, "handler": 7, "document_chang": 7, "index_object": 7, "turn": [7, 12, 15], "off": [7, 12], "flood": 7, "connection_rout": 7, "for_writ": 7, "get_unified_index": 7, "get_index": 7, "update_object": 7, "expand": 7, "deal": 7, "post_delet": 7, "remove_object": 7, "subprocess": 7, "backup": 7, "cp": 7, "bak": 7, "l": 7, "dump": 7, "output": [7, 15], "task_id": [7, 15], "check_output": 7, "dir_list": 7, "quit": [7, 12], "bit": 7, "completedprocess": 7, "tid": 7, "r": 7, "origin": [7, 9, 13], "returncod": 7, "captur": 7, "ll": 7, "pipe": 7, "stdout": 7, "easier": 7, "call_command": [7, 13], "clearsess": [7, 13], "session": 7, "kernel": 7, "densiti": 7, "estim": 7, "parzen": 7, "techniqu": 7, "adapt": 7, "sebastian": 7, "raschka": 7, "blog": 7, "numpi": 7, "delete_group": [7, 8, 15], "parzen_estim": 7, "x_sampl": 7, "point_x": 7, "k_n": 7, "row": 7, "x_i": 7, "newaxi": 7, "ab": 7, "break": 7, "len": 7, "shape": 7, "collat": [7, 11], "parzen_async": 7, "mu_vec": 7, "arrai": 7, "cov_mat": 7, "sampl": 7, "random": [7, 13], "multivariate_norm": 7, "10000": 7, "width": 7, "linspac": 7, "label": [7, 8, 9, 15], "w": [7, 13], "optim": 7, "distribut": 7, "give": 7, "written": 7, "async_it": [7, 11, 15], "automat": [7, 10], "iter": [7, 8, 9], "result_id": 7, "8080": 7, "file": [7, 10], "directori": 7, "worker_hc": 7, "whatev": 7, "d": [7, 13], "modifi": 7, "basehttprequesthandl": 7, "httpserver": 7, "mtt_app": 7, "email_use_tl": 7, "correct": 7, "path": [7, 14], "setdefault": 7, "django_settings_modul": 7, "stuff": 7, "come": [7, 12], "serverport": 7, "healthcheckserv": 7, "do_get": 7, "happy_clust": 7, "total_clust": 7, "get_al": [7, 12], "idl": [7, 12], "200": [7, 15], "respons": 7, "happi": 7, "response_cod": 7, "send_respons": 7, "send_head": 7, "content": [7, 9], "text": 7, "html": 7, "end_head": 7, "wfile": 7, "byte": 7, "head": 7, "titl": [7, 10], "heath": 7, "p": 7, "__name__": 7, "__main__": 7, "webserv": 7, "serve_forev": 7, "keyboardinterrupt": 7, "server_clos": 7, "submit": [7, 10], "github": [7, 9, 10], "togeth": 8, "rang": [8, 11, 15], "modf": [8, 15], "achiev": [8, 13, 15], "much": [8, 10, 15], "faster": [8, 10], "fetch_group": [8, 15], "queryset": [8, 15], "count_group": 8, "failure_count": 8, "winter": 8, "speaker": 8, "alpha": 8, "ceil": 8, "group_count": [8, 15], "group_result": [8, 15], "group_delet": [8, 15], "asynctask": [8, 9], "associ": 8, "nativ": 9, "applic": [9, 10], "fork": [9, 10], "big": 9, "thank": 9, "ilan": 9, "steemer": 9, "unfortun": [9, 10], "stall": 9, "june": 9, "2021": 9, "depend": [9, 10, 12], "doc": 9, "bug": 9, "fix": 9, "repositori": 9, "koed00": 9, "cron": [9, 10, 13], "multi": 9, "redi": [9, 10, 12, 15], "sq": [9, 10], "9": [9, 10, 13], "11": [9, 10], "english": 9, "german": 9, "french": 9, "ons": 9, "daemonize_work": 9, "max_rss": 9, "time_zon": 9, "max_attempt": 9, "save_limit_p": 9, "guard_cycl": 9, "catch_up": [9, 13], "mongo_db": 9, "poll": [9, 13], "error_report": 9, "oper": 9, "procfil": 9, "legend": 9, "subscrib": 9, "architectur": 9, "pusher": [9, 12], "email": [9, 10], "haystack": 9, "shell": [9, 13], "installed_app": 10, "app": 10, "choos": 10, "appropri": 10, "swap": 10, "go": 10, "uninstal": 10, "well": 10, "Then": 10, "aim": 10, "standard": 10, "picklefield": 10, "bless": [10, 12], "displai": 10, "andi": 10, "mccurdi": 10, "interfac": 10, "giampaolo": 10, "rodola": 10, "setproctitl": 10, "daniel": 10, "varrazzo": 10, "hiredi": 10, "parser": 10, "maintain": 10, "team": 10, "pythonpars": 10, "deprec": 10, "boto": 10, "offici": 10, "bind": 10, "pyrollbar": 10, "account": 10, "cronit": [10, 13], "pars": [10, 13], "express": [10, 13], "known": 10, "qsize": [10, 12], "under": [10, 15], "featur": [10, 15], "osx": 10, "awar": 10, "fake": 10, "assign": [10, 13], "log": [10, 12], "abil": 10, "abl": 10, "getppid": 10, "older": 10, "occasion": 10, "reli": [10, 15], "curs": 10, "There": 10, "christoph": 10, "gohlk": 10, "regress": 10, "earlier": 10, "strive": 10, "last": [10, 12, 13], "two": [10, 13, 14], "major": 10, "At": 10, "result_list": 11, "1000": 11, "speed": [11, 15], "args_it": 11, "uuid": [11, 15], "pypi": 12, "org": 12, "live": 12, "qmonitor": 12, "among": 12, "local": 12, "ok": 12, "shut": 12, "rise": 12, "green": 12, "unusu": 12, "suffer": 12, "uptim": 12, "press": 12, "summari": 12, "qinfo": 12, "sum": 12, "over": 12, "dai": [12, 13], "averag": 12, "avg": 12, "skew": 12, "straight": [12, 15], "cluster_id": 12, "know": [12, 13], "1234": 12, "correspond": 12, "tob": 12, "birth": 12, "string": [12, 13, 14], "repres": [12, 15], "task_q_siz": 12, "done_q_s": 12, "empty_queu": 12, "classmethod": [12, 15], "activ": 12, "print_result": [13, 15], "Or": 13, "daili": 13, "q_option": 13, "specifi": 13, "properti": 13, "broker_nam": 13, "sqrt": 13, "broker_1": 13, "todai": 13, "hypot": 13, "utcnow": 13, "18": 13, "restrain": 13, "specif": 13, "my_clust": 13, "term": 13, "past": 13, "reschedul": 13, "futur": 13, "intend": [13, 15], "facilit": 13, "suitabl": 13, "situat": 13, "skip": 13, "find": 13, "intended_date_kwarg": 13, "isoformat": 13, "wrap": 13, "clear_sessions_command": 13, "dot": 13, "nce": 13, "m": 13, "nute": 13, "ourli": 13, "aili": 13, "eekli": 13, "onthli": 13, "uarterli": 13, "y": 13, "earli": 13, "ron": 13, "n": 13, "fallback": 13, "primari": 13, "assum": 13, "weekli": 13, "biweekli": 13, "monthli": 13, "bimonthli": 13, "quarterli": 13, "yearli": 13, "describ": [13, 15], "last_run": 13, "week": 13, "bw": 13, "month": 13, "tricki": 13, "31st": 13, "28th": 13, "subsequ": 13, "bm": 13, "year": 13, "caution": 13, "appli": 13, "februari": 13, "29th": 13, "emit": 14, "lifecycl": 14, "pre_enqueu": 14, "given": 14, "post_spawn": 14, "proc_nam": 14, "pre_execut": 14, "callabl": 14, "nonetheless": 14, "post_execut": 14, "done": 14, "my_pre_enqueue_callback": 14, "my_pre_execute_callback": 14, "my_post_execute_callback": 14, "my_post_spawn_callback": 14, "offload": 15, "task_result": 15, "simul": 15, "integ": 15, "where": 15, "overwrit": 15, "auto": 15, "opt": 15, "background": 15, "mode": 15, "max": 15, "retriev": 15, "interest": 15, "final": 15, "memcach": 15, "significantli": 15, "compar": 15, "relat": 15, "perman": 15, "cleanup": 15, "strategi": 15, "lru": 15, "stale": 15, "evict": 15, "50m": 15, "appear": 15, "easili": 15, "hundr": 15, "frexp": 15, "exact": 15, "inject": 15, "buggi": 15, "examin": 15, "importerror": 15, "No": 15, "bypass": 15, "debug": 15, "reus": 15, "economi": 15, "previous": 15, "renam": 15, "get_task": 15, "delete_cach": 15, "uuid4": 15, "human": 15, "uniqu": 15, "problem": 15, "time_taken": 15, "taken": 15, "get_result": 15, "get_result_group": 15, "get_task_group": 15, "get_group_count": 15}, "objects": {"": [[2, 0, 1, "", "Broker"], [12, 0, 1, "", "Stat"], [5, 4, 0, "-", "django_q"]], "Broker": [[2, 1, 1, "", "acknowledge"], [2, 1, 1, "", "async_task"], [2, 1, 1, "", "delete"], [2, 1, 1, "", "delete_queue"], [2, 1, 1, "", "dequeue"], [2, 1, 1, "", "fail"], [2, 1, 1, "", "info"], [2, 1, 1, "", "lock_size"], [2, 1, 1, "", "ping"], [2, 1, 1, "", "purge_queue"], [2, 1, 1, "", "queue_size"]], "Stat": [[12, 2, 1, "", "cluster_id"], [12, 2, 1, "", "done_q_size"], [12, 1, 1, "", "empty_queues"], [12, 1, 1, "", "get"], [12, 1, 1, "", "get_all"], [12, 2, 1, "", "monitor"], [12, 2, 1, "", "pusher"], [12, 2, 1, "", "reincarnations"], [12, 2, 1, "", "sentinel"], [12, 2, 1, "", "status"], [12, 2, 1, "", "task_q_size"], [12, 2, 1, "", "tob"], [12, 1, 1, "", "uptime"], [12, 2, 1, "", "workers"]], "brokers": [[2, 3, 1, "", "get_broker"]], "django_q": [[15, 0, 1, "", "AsyncTask"], [3, 0, 1, "", "Chain"], [4, 0, 1, "", "Cluster"], [15, 0, 1, "", "Failure"], [11, 0, 1, "", "Iter"], [13, 0, 1, "", "Schedule"], [15, 0, 1, "", "Success"], [15, 0, 1, "", "Task"], [3, 3, 1, "", "async_chain"], [11, 3, 1, "", "async_iter"], [15, 3, 1, "", "async_task"], [8, 3, 1, "", "count_group"], [15, 3, 1, "", "delete_cached"], [8, 3, 1, "", "delete_group"], [15, 3, 1, "", "fetch"], [8, 3, 1, "", "fetch_group"], [15, 3, 1, "", "queue_size"], [15, 3, 1, "", "result"], [8, 3, 1, "", "result_group"], [13, 3, 1, "", "schedule"]], "django_q.AsyncTask": [[15, 2, 1, "", "args"], [15, 2, 1, "", "broker"], [15, 2, 1, "", "cached"], [15, 1, 1, "", "fetch"], [15, 1, 1, "", "fetch_group"], [15, 2, 1, "", "func"], [15, 2, 1, "", "group"], [15, 2, 1, "", "hook"], [15, 2, 1, "", "id"], [15, 2, 1, "", "kwargs"], [15, 1, 1, "", "result"], [15, 1, 1, "", "result_group"], [15, 1, 1, "", "run"], [15, 2, 1, "", "save"], [15, 2, 1, "", "started"], [15, 2, 1, "", "sync"]], "django_q.Chain": [[3, 1, 1, "", "append"], [3, 1, 1, "", "current"], [3, 1, 1, "", "fetch"], [3, 1, 1, "", "length"], [3, 1, 1, "", "result"], [3, 1, 1, "", "run"]], "django_q.Cluster": [[4, 2, 1, "", "has_stopped"], [4, 2, 1, "", "host"], [4, 2, 1, "", "is_running"], [4, 2, 1, "", "is_starting"], [4, 2, 1, "", "is_stopping"], [4, 2, 1, "", "pid"], [4, 2, 1, "", "sentinel"], [4, 1, 1, "", "start"], [4, 2, 1, "", "start_event"], [4, 1, 1, "", "stat"], [4, 1, 1, "", "stop"], [4, 2, 1, "", "stop_event"], [4, 2, 1, "", "timeout"]], "django_q.Iter": [[11, 1, 1, "", "append"], [11, 1, 1, "", "fetch"], [11, 1, 1, "", "length"], [11, 1, 1, "", "result"], [11, 1, 1, "", "run"]], "django_q.Schedule": [[13, 2, 1, "", "BIMONTHLY"], [13, 2, 1, "", "BIWEEKLY"], [13, 2, 1, "", "CRON"], [13, 2, 1, "", "DAILY"], [13, 2, 1, "", "HOURLY"], [13, 2, 1, "", "MINUTES"], [13, 2, 1, "", "MONTHLY"], [13, 2, 1, "", "ONCE"], [13, 2, 1, "", "QUARTERLY"], [13, 2, 1, "", "TYPE"], [13, 2, 1, "", "WEEKLY"], [13, 2, 1, "", "YEARLY"], [13, 2, 1, "", "args"], [13, 2, 1, "", "cluster"], [13, 2, 1, "", "cron"], [13, 2, 1, "", "func"], [13, 2, 1, "", "hook"], [13, 2, 1, "", "id"], [13, 2, 1, "", "intended_date_kwarg"], [13, 2, 1, "", "kwargs"], [13, 1, 1, "", "last_run"], [13, 2, 1, "", "minutes"], [13, 2, 1, "", "name"], [13, 2, 1, "", "next_run"], [13, 2, 1, "", "repeats"], [13, 2, 1, "", "schedule_type"], [13, 1, 1, "", "success"], [13, 2, 1, "", "task"]], "django_q.Task": [[15, 2, 1, "", "args"], [15, 1, 1, "", "delete_group"], [15, 2, 1, "", "func"], [15, 1, 1, "", "get_group_count"], [15, 1, 1, "", "get_result"], [15, 1, 1, "", "get_result_group"], [15, 1, 1, "", "get_task"], [15, 1, 1, "", "get_task_group"], [15, 1, 1, "", "group_count"], [15, 1, 1, "", "group_delete"], [15, 1, 1, "", "group_result"], [15, 2, 1, "", "hook"], [15, 2, 1, "", "id"], [15, 2, 1, "", "kwargs"], [15, 2, 1, "", "name"], [15, 2, 1, "", "result"], [15, 2, 1, "", "started"], [15, 2, 1, "", "stopped"], [15, 2, 1, "", "success"], [15, 1, 1, "", "time_taken"]]}, "objtypes": {"0": "py:class", "1": "py:method", "2": "py:attribute", "3": "py:function", "4": "py:module"}, "objnames": {"0": ["py", "class", "Python class"], "1": ["py", "method", "Python method"], "2": ["py", "attribute", "Python attribute"], "3": ["py", "function", "Python function"], "4": ["py", "module", "Python module"]}, "titleterms": {"admin": 0, "page": 0, "success": 0, "task": [0, 1, 14, 15], "fail": 0, "schedul": [0, 1, 5, 13], "repeat": 0, "next": 0, "run": 0, "last": 0, "queu": 0, "architectur": 1, "sign": 1, "broker": [1, 2, 15], "pusher": 1, "worker": [1, 5, 14], "monitor": [1, 12], "sentinel": 1, "timeout": [1, 5, 15], "stop": 1, "procedur": 1, "redi": [2, 5], "ironmq": 2, "amazon": 2, "sq": [2, 5], "mongodb": 2, "django": [2, 9, 10], "orm": [2, 5], "custom": 2, "refer": [2, 3, 4, 8, 11, 12, 13, 15], "chain": 3, "cluster": 4, "multipl": 4, "queue": 4, "us": 4, "procfil": 4, "process": [4, 14], "manag": [4, 13], "configur": 5, "name": 5, "daemonize_work": 5, "recycl": 5, "max_rss": 5, "time_zon": 5, "ack_failur": [5, 15], "max_attempt": 5, "retri": 5, "compress": 5, "save_limit": 5, "save_limit_p": 5, "guard_cycl": 5, "sync": [5, 15], "queue_limit": 5, "label": 5, "catch_up": 5, "django_redi": 5, "iron_mq": 5, "mongo": 5, "mongo_db": 5, "broker_class": 5, "bulk": 5, "poll": 5, "cach": [5, 15], "error_report": 5, "cpu_affin": 5, "alt_clust": 5, "error": 6, "exampl": 7, "email": 7, "signal": [7, 14], "report": 7, "haystack": 7, "shell": 7, "group": [7, 8, 15], "http": 7, "health": 7, "check": 7, "welcom": 9, "q2": [9, 10], "featur": 9, "instal": 10, "migrat": 10, "from": 10, "q": 10, "requir": 10, "option": 10, "add": 10, "ons": 10, "o": 10, "x": 10, "window": 10, "python": 10, "open": 10, "sourc": 10, "packag": 10, "iter": 11, "legend": 12, "host": 12, "id": 12, "state": 12, "pool": [12, 15], "tq": 12, "rq": 12, "rc": 12, "up": 12, "info": 12, "statu": 12, "miss": 13, "command": 13, "avail": 14, "befor": 14, "enqueu": 14, "after": 14, "spawn": 14, "execut": 14, "subscrib": 14, "async_task": 15, "hook": 15, "save": 15, "task_nam": 15, "q_option": 15, "asynctask": 15, "oper": 15, "synchron": 15, "test": 15, "connect": 15}, "envversion": {"sphinx.domains.c": 3, "sphinx.domains.changeset": 1, "sphinx.domains.citation": 1, "sphinx.domains.cpp": 9, "sphinx.domains.index": 1, "sphinx.domains.javascript": 3, "sphinx.domains.math": 2, "sphinx.domains.python": 4, "sphinx.domains.rst": 2, "sphinx.domains.std": 2, "sphinx.ext.todo": 2, "sphinx.ext.intersphinx": 1, "sphinx": 60}, "alltitles": {"Admin pages": [[0, "admin-pages"]], "Successful tasks": [[0, "successful-tasks"]], "Failed tasks": [[0, "failed-tasks"]], "Scheduled tasks": [[0, "scheduled-tasks"]], "Repeats": [[0, "repeats"]], "Next run": [[0, "next-run"]], "Last run": [[0, "last-run"]], "Success": [[0, "success"]], "Queued tasks": [[0, "queued-tasks"]], "Architecture": [[1, "architecture"]], "Signed Tasks": [[1, "signed-tasks"]], "Broker": [[1, "broker"]], "Pusher": [[1, "pusher"]], "Worker": [[1, "worker"]], "Monitor": [[1, "monitor"], [12, "monitor"]], "Sentinel": [[1, "sentinel"]], "Timeouts": [[1, "timeouts"]], "Scheduler": [[1, "scheduler"]], "Stop procedure": [[1, "stop-procedure"]], "Brokers": [[2, "brokers"]], "Redis": [[2, "redis"]], "IronMQ": [[2, "ironmq"]], "Amazon SQS": [[2, "amazon-sqs"]], "MongoDB": [[2, "mongodb"]], "Django ORM": [[2, "django-orm"]], "Custom Broker": [[2, "custom-broker"]], "Reference": [[2, "reference"], [3, "reference"], [4, "reference"], [8, "reference"], [11, "reference"], [12, "reference"], [13, "reference"], [15, "reference"]], "Chains": [[3, "chains"]], "Cluster": [[4, "cluster"]], "Multiple Clusters": [[4, "multiple-clusters"]], "Multiple Queues": [[4, "multiple-queues"]], "Using a Procfile": [[4, "using-a-procfile"]], "Process managers": [[4, "process-managers"]], "Configuration": [[5, "configuration"]], "name": [[5, "name"]], "workers": [[5, "workers"]], "daemonize_workers": [[5, "daemonize-workers"]], "recycle": [[5, "recycle"]], "max_rss": [[5, "max-rss"]], "timeout": [[5, "timeout"], [15, "timeout"]], "time_zone": [[5, "time-zone"]], "ack_failures": [[5, "ack-failures"]], "max_attempts": [[5, "max-attempts"]], "retry": [[5, "retry"]], "compress": [[5, "compress"]], "save_limit": [[5, "save-limit"]], "save_limit_per": [[5, "save-limit-per"]], "guard_cycle": [[5, "guard-cycle"]], "sync": [[5, "sync"], [15, "sync"]], "queue_limit": [[5, "queue-limit"]], "label": [[5, "label"]], "catch_up": [[5, "catch-up"]], "redis": [[5, "redis"]], "django_redis": [[5, "django-redis"]], "iron_mq": [[5, "iron-mq"]], "sqs": [[5, "sqs"]], "orm": [[5, "orm"]], "mongo": [[5, "mongo"]], "mongo_db": [[5, "mongo-db"]], "broker_class": [[5, "broker-class"]], "bulk": [[5, "bulk"]], "poll": [[5, "poll"]], "cache": [[5, "cache"]], "cached": [[5, "cached"], [15, "cached"]], "scheduler": [[5, "scheduler"]], "error_reporter": [[5, "error-reporter"]], "cpu_affinity": [[5, "cpu-affinity"]], "ALT_CLUSTERS": [[5, "alt-clusters"]], "Errors": [[6, "errors"]], "Examples": [[7, "examples"]], "Emails": [[7, "emails"]], "Signals": [[7, "signals"], [14, "signals"]], "Reports": [[7, "reports"]], "Haystack": [[7, "haystack"]], "Shell": [[7, "shell"]], "Groups": [[7, "groups"], [8, "groups"]], "Http Health Check": [[7, "http-health-check"]], "Welcome to Django Q2": [[9, "welcome-to-django-q2"]], "Features": [[9, "features"]], "Installation": [[10, "installation"]], "Migrate from Django-Q to Django-Q2": [[10, "migrate-from-django-q-to-django-q2"]], "Requirements": [[10, "requirements"]], "Optional": [[10, "optional"]], "Add-ons": [[10, "add-ons"]], "OS X": [[10, "os-x"]], "Windows": [[10, "windows"]], "Python": [[10, "python"]], "Open-source packages": [[10, "open-source-packages"]], "Django": [[10, "django"]], "Iterable": [[11, "iterable"]], "Legend": [[12, "legend"]], "Host": [[12, "host"]], "Id": [[12, "id"]], "State": [[12, "state"]], "Pool": [[12, "pool"]], "TQ": [[12, "tq"]], "RQ": [[12, "rq"]], "RC": [[12, "rc"]], "Up": [[12, "up"]], "Info": [[12, "info"]], "Status": [[12, "status"]], "Schedules": [[13, "schedules"]], "Schedule": [[13, "schedule"]], "Missed schedules": [[13, "missed-schedules"]], "Management Commands": [[13, "management-commands"]], "Available signals": [[14, "available-signals"]], "Before enqueuing a task": [[14, "before-enqueuing-a-task"]], "After spawning a worker process": [[14, "after-spawning-a-worker-process"]], "Before executing a task": [[14, "before-executing-a-task"]], "After executing a task": [[14, "after-executing-a-task"]], "Subscribing to a signal": [[14, "subscribing-to-a-signal"]], "Tasks": [[15, "tasks"]], "async_task()": [[15, "async-task"]], "hook": [[15, "hook"]], "group": [[15, "group"]], "save": [[15, "save"]], "ack_failure": [[15, "ack-failure"]], "broker": [[15, "broker"]], "task_name": [[15, "task-name"]], "q_options": [[15, "q-options"]], "AsyncTask": [[15, "asynctask"]], "Cached operations": [[15, "cached-operations"]], "Synchronous testing": [[15, "synchronous-testing"]], "Connection pooling": [[15, "connection-pooling"]]}, "indexentries": {"broker (built-in class)": [[2, "Broker"]], "acknowledge() (broker method)": [[2, "Broker.acknowledge"]], "async_task() (broker method)": [[2, "Broker.async_task"]], "brokers.get_broker()": [[2, "brokers.get_broker"]], "built-in function": [[2, "brokers.get_broker"]], "delete() (broker method)": [[2, "Broker.delete"]], "delete_queue() (broker method)": [[2, "Broker.delete_queue"]], "dequeue() (broker method)": [[2, "Broker.dequeue"]], "fail() (broker method)": [[2, "Broker.fail"]], "info() (broker method)": [[2, "Broker.info"]], "lock_size() (broker method)": [[2, "Broker.lock_size"]], "ping() (broker method)": [[2, "Broker.ping"]], "purge_queue() (broker method)": [[2, "Broker.purge_queue"]], "queue_size() (broker method)": [[2, "Broker.queue_size"]], "chain (class in django_q)": [[3, "django_q.Chain"]], "append() (chain method)": [[3, "django_q.Chain.append"]], "async_chain() (in module django_q)": [[3, "django_q.async_chain"]], "current() (chain method)": [[3, "django_q.Chain.current"]], "fetch() (chain method)": [[3, "django_q.Chain.fetch"]], "length() (chain method)": [[3, "django_q.Chain.length"]], "result() (chain method)": [[3, "django_q.Chain.result"]], "run() (chain method)": [[3, "django_q.Chain.run"]], "cluster (class in django_q)": [[4, "django_q.Cluster"]], "has_stopped (cluster attribute)": [[4, "django_q.Cluster.has_stopped"]], "host (cluster attribute)": [[4, "django_q.Cluster.host"]], "is_running (cluster attribute)": [[4, "django_q.Cluster.is_running"]], "is_starting (cluster attribute)": [[4, "django_q.Cluster.is_starting"]], "is_stopping (cluster attribute)": [[4, "django_q.Cluster.is_stopping"]], "pid (cluster attribute)": [[4, "django_q.Cluster.pid"]], "sentinel (cluster attribute)": [[4, "django_q.Cluster.sentinel"]], "start() (cluster method)": [[4, "django_q.Cluster.start"]], "start_event (cluster attribute)": [[4, "django_q.Cluster.start_event"]], "stat() (cluster method)": [[4, "django_q.Cluster.stat"]], "stop() (cluster method)": [[4, "django_q.Cluster.stop"]], "stop_event (cluster attribute)": [[4, "django_q.Cluster.stop_event"]], "timeout (cluster attribute)": [[4, "django_q.Cluster.timeout"]], "django_q": [[5, "module-django_q"]], "module": [[5, "module-django_q"]], "count_group() (in module django_q)": [[8, "django_q.count_group"]], "delete_group() (in module django_q)": [[8, "django_q.delete_group"]], "fetch_group() (in module django_q)": [[8, "django_q.fetch_group"]], "result_group() (in module django_q)": [[8, "django_q.result_group"]], "iter (class in django_q)": [[11, "django_q.Iter"]], "append() (iter method)": [[11, "django_q.Iter.append"]], "async_iter() (in module django_q)": [[11, "django_q.async_iter"]], "fetch() (iter method)": [[11, "django_q.Iter.fetch"]], "length() (iter method)": [[11, "django_q.Iter.length"]], "result() (iter method)": [[11, "django_q.Iter.result"]], "run() (iter method)": [[11, "django_q.Iter.run"]], "stat (built-in class)": [[12, "Stat"]], "cluster_id (stat attribute)": [[12, "Stat.cluster_id"]], "done_q_size (stat attribute)": [[12, "Stat.done_q_size"]], "empty_queues() (stat method)": [[12, "Stat.empty_queues"]], "get() (stat class method)": [[12, "Stat.get"]], "get_all() (stat class method)": [[12, "Stat.get_all"]], "monitor (stat attribute)": [[12, "Stat.monitor"]], "pusher (stat attribute)": [[12, "Stat.pusher"]], "reincarnations (stat attribute)": [[12, "Stat.reincarnations"]], "sentinel (stat attribute)": [[12, "Stat.sentinel"]], "status (stat attribute)": [[12, "Stat.status"]], "task_q_size (stat attribute)": [[12, "Stat.task_q_size"]], "tob (stat attribute)": [[12, "Stat.tob"]], "uptime() (stat method)": [[12, "Stat.uptime"]], "workers (stat attribute)": [[12, "Stat.workers"]], "bimonthly (schedule attribute)": [[13, "django_q.Schedule.BIMONTHLY"]], "biweekly (schedule attribute)": [[13, "django_q.Schedule.BIWEEKLY"]], "cron (schedule attribute)": [[13, "django_q.Schedule.CRON"], [13, "django_q.Schedule.cron"]], "daily (schedule attribute)": [[13, "django_q.Schedule.DAILY"]], "hourly (schedule attribute)": [[13, "django_q.Schedule.HOURLY"]], "minutes (schedule attribute)": [[13, "django_q.Schedule.MINUTES"], [13, "django_q.Schedule.minutes"]], "monthly (schedule attribute)": [[13, "django_q.Schedule.MONTHLY"]], "once (schedule attribute)": [[13, "django_q.Schedule.ONCE"]], "quarterly (schedule attribute)": [[13, "django_q.Schedule.QUARTERLY"]], "schedule (class in django_q)": [[13, "django_q.Schedule"]], "type (schedule attribute)": [[13, "django_q.Schedule.TYPE"]], "weekly (schedule attribute)": [[13, "django_q.Schedule.WEEKLY"]], "yearly (schedule attribute)": [[13, "django_q.Schedule.YEARLY"]], "args (schedule attribute)": [[13, "django_q.Schedule.args"]], "cluster (schedule attribute)": [[13, "django_q.Schedule.cluster"]], "func (schedule attribute)": [[13, "django_q.Schedule.func"]], "hook (schedule attribute)": [[13, "django_q.Schedule.hook"]], "id (schedule attribute)": [[13, "django_q.Schedule.id"]], "intended_date_kwarg (schedule attribute)": [[13, "django_q.Schedule.intended_date_kwarg"]], "kwargs (schedule attribute)": [[13, "django_q.Schedule.kwargs"]], "last_run() (schedule method)": [[13, "django_q.Schedule.last_run"]], "name (schedule attribute)": [[13, "django_q.Schedule.name"]], "next_run (schedule attribute)": [[13, "django_q.Schedule.next_run"]], "repeats (schedule attribute)": [[13, "django_q.Schedule.repeats"]], "schedule() (in module django_q)": [[13, "django_q.schedule"]], "schedule_type (schedule attribute)": [[13, "django_q.Schedule.schedule_type"]], "success() (schedule method)": [[13, "django_q.Schedule.success"]], "task (schedule attribute)": [[13, "django_q.Schedule.task"]], "asynctask (class in django_q)": [[15, "django_q.AsyncTask"]], "failure (class in django_q)": [[15, "django_q.Failure"]], "success (class in django_q)": [[15, "django_q.Success"]], "task (class in django_q)": [[15, "django_q.Task"]], "args (asynctask attribute)": [[15, "django_q.AsyncTask.args"]], "args (task attribute)": [[15, "django_q.Task.args"]], "async_task() (in module django_q)": [[15, "django_q.async_task"]], "broker (asynctask attribute)": [[15, "django_q.AsyncTask.broker"]], "cached (asynctask attribute)": [[15, "django_q.AsyncTask.cached"]], "delete_cached() (in module django_q)": [[15, "django_q.delete_cached"]], "delete_group() (task class method)": [[15, "django_q.Task.delete_group"]], "fetch() (asynctask method)": [[15, "django_q.AsyncTask.fetch"]], "fetch() (in module django_q)": [[15, "django_q.fetch"]], "fetch_group() (asynctask method)": [[15, "django_q.AsyncTask.fetch_group"]], "func (asynctask attribute)": [[15, "django_q.AsyncTask.func"]], "func (task attribute)": [[15, "django_q.Task.func"]], "get_group_count() (task class method)": [[15, "django_q.Task.get_group_count"]], "get_result() (task class method)": [[15, "django_q.Task.get_result"]], "get_result_group() (task class method)": [[15, "django_q.Task.get_result_group"]], "get_task() (task class method)": [[15, "django_q.Task.get_task"]], "get_task_group() (task class method)": [[15, "django_q.Task.get_task_group"]], "group (asynctask attribute)": [[15, "django_q.AsyncTask.group"]], "group_count() (task method)": [[15, "django_q.Task.group_count"]], "group_delete() (task method)": [[15, "django_q.Task.group_delete"]], "group_result() (task method)": [[15, "django_q.Task.group_result"]], "hook (asynctask attribute)": [[15, "django_q.AsyncTask.hook"]], "hook (task attribute)": [[15, "django_q.Task.hook"]], "id (asynctask attribute)": [[15, "django_q.AsyncTask.id"]], "id (task attribute)": [[15, "django_q.Task.id"]], "kwargs (asynctask attribute)": [[15, "django_q.AsyncTask.kwargs"]], "kwargs (task attribute)": [[15, "django_q.Task.kwargs"]], "name (task attribute)": [[15, "django_q.Task.name"]], "queue_size() (in module django_q)": [[15, "django_q.queue_size"]], "result (task attribute)": [[15, "django_q.Task.result"]], "result() (asynctask method)": [[15, "django_q.AsyncTask.result"]], "result() (in module django_q)": [[15, "django_q.result"]], "result_group() (asynctask method)": [[15, "django_q.AsyncTask.result_group"]], "run() (asynctask method)": [[15, "django_q.AsyncTask.run"]], "save (asynctask attribute)": [[15, "django_q.AsyncTask.save"]], "started (asynctask attribute)": [[15, "django_q.AsyncTask.started"]], "started (task attribute)": [[15, "django_q.Task.started"]], "stopped (task attribute)": [[15, "django_q.Task.stopped"]], "success (task attribute)": [[15, "django_q.Task.success"]], "sync (asynctask attribute)": [[15, "django_q.AsyncTask.sync"]], "time_taken() (task method)": [[15, "django_q.Task.time_taken"]]}})