{ "_id": "6a1edf81b401979e734105ce", "Package": "rrq", "Title": "Simple Redis Queue", "Version": "0.7.23", "Authors@R": "c(person(\"Rich\", \"FitzJohn\", role = c(\"aut\", \"cre\"),\nemail = \"rich.fitzjohn@gmail.com\"),\nperson(\"Robert\", \"Ashton\", role = \"aut\"),\nperson(\"Imperial College of Science, Technology and Medicine\",\nrole = \"cph\"))", "Description": "Simple Redis queue in R.", "License": "MIT + file LICENSE", "URL": "https://mrc-ide.github.io/rrq, https://github.com/mrc-ide/rrq", "BugReports": "https://github.com/mrc-ide/rrq/issues", "RoxygenNote": "7.3.2", "Encoding": "UTF-8", "Roxygen": "list(markdown = TRUE, r6 = TRUE)", "Language": "en-GB", "Config/testthat/edition": "3", "VignetteBuilder": "knitr", "Remotes": [ "reside-ic/logwatch" ], "Config/pak/sysreqs": "libhiredis-dev libssl-dev", "Repository": "https://vimc.r-universe.dev", "Date/Publication": "2025-06-24 12:48:02 UTC", "RemoteUrl": "https://github.com/mrc-ide/rrq", "RemoteRef": "master", "RemoteSha": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "NeedsCompilation": "no", "Packaged": { "Date": "2026-05-20 07:36:26 UTC", "User": "root" }, "Author": "Rich FitzJohn [aut, cre],\nRobert Ashton [aut],\nImperial College of Science, Technology and Medicine [cph]", "Maintainer": "Rich FitzJohn ", "MD5sum": "c87e4c451d16d008215100e3777d778d", "_user": "vimc", "_type": "src", "_file": "rrq_0.7.23.tar.gz", "_fileid": "61f0a15750b1294cf707cf9f43de3e5205d12b010807f75d097a9554e250c837", "_filesize": 453949, "_sha256": "61f0a15750b1294cf707cf9f43de3e5205d12b010807f75d097a9554e250c837", "_created": "2026-05-20T07:36:26.000Z", "_published": "2026-06-02T13:49:53.237Z", "_distro": "noble", "_jobs": [ { "job": 79086170162, "time": 152, "config": "linux-devel-x86_64", "r": "4.7.0", "check": "OK", "artifact": "7103990683" }, { "job": 79086170418, "time": 146, "config": "linux-release-x86_64", "r": "4.6.0", "check": "OK", "artifact": "7103988201" }, { "job": 79086170337, "time": 99, "config": "macos-oldrel-arm64", "r": "4.5.3", "check": "OK", "artifact": "7103974142" }, { "job": 79086170695, "time": 106, "config": "macos-release-arm64", "r": "4.6.0", "check": "OK", "artifact": "7103975891" }, { "job": 79086170812, "time": 192, "config": "source", "r": "4.6.0", "check": "OK", "artifact": "7103941494" }, { "job": 79086169120, "time": 116, "config": "wasm-release", "r": "4.6.0", "check": "OK", "artifact": "7359578695" }, { "job": 79086170057, "time": 159, "config": "windows-devel", "r": "4.7.0", "check": "OK", "artifact": "7103992804" }, { "job": 79086169925, "time": 100, "config": "windows-oldrel", "r": "4.5.3", "check": "OK", "artifact": "7103974286" }, { "job": 79086170286, "time": 106, "config": "windows-release", "r": "4.6.0", "check": "OK", "artifact": "7103975692" } ], "_buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054", "_status": "success", "_host": "GitHub-Actions", "_upstream": "https://github.com/mrc-ide/rrq", "_commit": { "id": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "author": "anmol thapar ", "committer": "anmol thapar ", "message": "Revert \"Change termination signal from SIGTERM to SIGINT for task termination\"\n\nThis reverts commit 37efe34522378391627d292fbb0bdb85b46e1d85.\n", "time": 1750769282 }, "_maintainer": { "name": "Rich FitzJohn", "email": "rich.fitzjohn@gmail.com", "login": "richfitz", "mastodon": "@richfitz@fosstodon.org", "description": "", "uuid": 1558093 }, "_registered": true, "_dependencies": [ { "package": "R6", "role": "Imports" }, { "package": "callr", "version": ">= 3.7.0", "role": "Imports" }, { "package": "cli", "role": "Imports" }, { "package": "docopt", "role": "Imports" }, { "package": "ids", "role": "Imports" }, { "package": "logwatch", "version": ">= 0.1.1", "role": "Imports" }, { "package": "progress", "role": "Imports" }, { "package": "redux", "version": ">= 1.0.0", "role": "Imports" }, { "package": "rlang", "role": "Imports" }, { "package": "knitr", "role": "Suggests" }, { "package": "markdown", "role": "Suggests" }, { "package": "mockery", "role": "Suggests" }, { "package": "processx", "role": "Suggests" }, { "package": "rmarkdown", "role": "Suggests" }, { "package": "testthat", "role": "Suggests" }, { "package": "withr", "role": "Suggests" } ], "_owner": "mrc-ide", "_selfowned": false, "_usedby": 2, "_updates": [ { "week": "2025-26", "n": 2 } ], "_tags": [], "_topics": [ "cluster", "infrastructure" ], "_stars": 25, "_contributors": [ { "user": "richfitz", "count": 804, "uuid": 1558093 }, { "user": "r-ash", "count": 139, "uuid": 39248272 }, { "user": "m-kusumgar", "count": 34, "uuid": 98405247 }, { "user": "plietar", "count": 11, "uuid": 1489775 }, { "user": "weshinsley", "count": 7, "uuid": 9009312 }, { "user": "absternator", "count": 2, "uuid": 68182660 }, { "user": "yapus", "count": 1, "uuid": 640352 } ], "_userbio": { "uuid": 26278316, "type": "organization", "name": "Vaccine Impact Modelling Consortium" }, "_downloads": { "count": 0, "source": "https://cranlogs.r-pkg.org/downloads/total/last-month/rrq" }, "_devurl": "https://github.com/mrc-ide/rrq", "_pkgdown": "https://mrc-ide.github.io/rrq", "_searchresults": 15, "_rbuild": "4.6.0", "_assets": [ "extra/citation.cff", "extra/citation.html", "extra/citation.json", "extra/citation.txt", "extra/contents.json", "extra/NEWS.html", "extra/NEWS.txt", "extra/readme.html", "extra/readme.md", "extra/rrq.html", "manual.pdf" ], "_cranurl": false, "_exports": [ "object_store", "rrq_configure", "rrq_controller", "rrq_controller2", "rrq_default_controller_clear", "rrq_default_controller_set", "rrq_deferred_list", "rrq_destroy", "rrq_envir", "rrq_heartbeat", "rrq_heartbeat_kill", "rrq_message_get_response", "rrq_message_has_response", "rrq_message_response_ids", "rrq_message_send", "rrq_message_send_and_wait", "rrq_queue_length", "rrq_queue_list", "rrq_queue_remove", "rrq_task_cancel", "rrq_task_create_bulk_call", "rrq_task_create_bulk_expr", "rrq_task_create_call", "rrq_task_create_expr", "rrq_task_data", "rrq_task_delete", "rrq_task_exists", "rrq_task_info", "rrq_task_list", "rrq_task_log", "rrq_task_overview", "rrq_task_position", "rrq_task_preceeding", "rrq_task_progress", "rrq_task_progress_update", "rrq_task_result", "rrq_task_results", "rrq_task_retry", "rrq_task_status", "rrq_task_times", "rrq_task_wait", "rrq_worker", "rrq_worker_config", "rrq_worker_config_list", "rrq_worker_config_read", "rrq_worker_config_save", "rrq_worker_config_save2", "rrq_worker_delete_exited", "rrq_worker_detect_exited", "rrq_worker_envir_refresh", "rrq_worker_envir_set", "rrq_worker_exists", "rrq_worker_info", "rrq_worker_len", "rrq_worker_list", "rrq_worker_list_exited", "rrq_worker_load", "rrq_worker_log_tail", "rrq_worker_process_log", "rrq_worker_script", "rrq_worker_spawn", "rrq_worker_spawn2", "rrq_worker_status", "rrq_worker_stop", "rrq_worker_task_id", "rrq_worker_wait" ], "_help": [ { "page": "object_store", "title": "rrq object store", "topics": [ "object_store" ] }, { "page": "object_store_offload_disk", "title": "Disk-based offload", "topics": [ "object_store_offload_disk" ] }, { "page": "rrq_controller", "title": "Create rrq controller", "topics": [ "rrq_controller" ] }, { "page": "rrq_default_controller_set", "title": "Register default controller", "topics": [ "rrq_default_controller_clear", "rrq_default_controller_set" ] }, { "page": "rrq_deferred_list", "title": "List deferred tasks", "topics": [ "rrq_deferred_list" ] }, { "page": "rrq_destroy", "title": "Destroy queue", "topics": [ "rrq_destroy" ] }, { "page": "rrq_envir", "title": "Create simple worker environments", "topics": [ "rrq_envir" ] }, { "page": "heartbeat", "title": "Create a heartbeat instance", "topics": [ "rrq_heartbeat" ] }, { "page": "rrq_heartbeat_kill", "title": "Kill a process running a heartbeat", "topics": [ "rrq_heartbeat_kill" ] }, { "page": "rrq_message_get_response", "title": "Get message response", "topics": [ "rrq_message_get_response" ] }, { "page": "rrq_message_has_response", "title": "Detect if message has response", "topics": [ "rrq_message_has_response" ] }, { "page": "rrq_message_response_ids", "title": "Return ids for messages with responses for a particular worker.", "topics": [ "rrq_message_response_ids" ] }, { "page": "rrq_message_send", "title": "Send message to workers", "topics": [ "rrq_message_send" ] }, { "page": "rrq_message_send_and_wait", "title": "Send a message and wait for response", "topics": [ "rrq_message_send_and_wait" ] }, { "page": "rrq_queue_length", "title": "Queue length", "topics": [ "rrq_queue_length" ] }, { "page": "rrq_queue_list", "title": "List queue contents", "topics": [ "rrq_queue_list" ] }, { "page": "rrq_queue_remove", "title": "Remove task ids from a queue", "topics": [ "rrq_queue_remove" ] }, { "page": "rrq_task_cancel", "title": "Cancel a task", "topics": [ "rrq_task_cancel" ] }, { "page": "rrq_task_create_bulk_call", "title": "Create bulk tasks from a call", "topics": [ "rrq_task_create_bulk_call" ] }, { "page": "rrq_task_create_bulk_expr", "title": "Create bulk tasks from an expression", "topics": [ "rrq_task_create_bulk_expr" ] }, { "page": "rrq_task_create_call", "title": "Create a task from a call", "topics": [ "rrq_task_create_call" ] }, { "page": "rrq_task_create_expr", "title": "Create a task based on an expression", "topics": [ "rrq_task_create_expr" ] }, { "page": "rrq_task_data", "title": "Fetch internal task data", "topics": [ "rrq_task_data" ] }, { "page": "rrq_task_delete", "title": "Delete tasks", "topics": [ "rrq_task_delete" ] }, { "page": "rrq_task_exists", "title": "Test if tasks exist", "topics": [ "rrq_task_exists" ] }, { "page": "rrq_task_info", "title": "Fetch task information", "topics": [ "rrq_task_info" ] }, { "page": "rrq_task_list", "title": "List all tasks", "topics": [ "rrq_task_list" ] }, { "page": "rrq_task_log", "title": "Fetch task logs", "topics": [ "rrq_task_log" ] }, { "page": "rrq_task_overview", "title": "High level task overview", "topics": [ "rrq_task_overview" ] }, { "page": "rrq_task_position", "title": "Find task position in queue", "topics": [ "rrq_task_position" ] }, { "page": "rrq_task_preceeding", "title": "List tasks ahead of a task", "topics": [ "rrq_task_preceeding" ] }, { "page": "rrq_task_progress", "title": "Fetch task progress information", "topics": [ "rrq_task_progress" ] }, { "page": "rrq_task_progress_update", "title": "Post task update", "topics": [ "rrq_task_progress_update" ] }, { "page": "rrq_task_result", "title": "Fetch single task result", "topics": [ "rrq_task_result" ] }, { "page": "rrq_task_results", "title": "Get the results of a group of tasks, returning them as a list. See rrq_task_result for getting the result of a single task.", "topics": [ "rrq_task_results" ] }, { "page": "rrq_task_retry", "title": "Retry tasks", "topics": [ "rrq_task_retry" ] }, { "page": "rrq_task_status", "title": "Fetch task statuses", "topics": [ "rrq_task_status" ] }, { "page": "rrq_task_times", "title": "Fetch task times", "topics": [ "rrq_task_times" ] }, { "page": "rrq_task_wait", "title": "Wait for group of tasks", "topics": [ "rrq_task_wait" ] }, { "page": "rrq_worker", "title": "rrq queue worker", "topics": [ "rrq_worker" ] }, { "page": "rrq_worker_config", "title": "Create worker configuration", "topics": [ "rrq_worker_config" ] }, { "page": "rrq_worker_config_list", "title": "List worker configurations", "topics": [ "rrq_worker_config_list" ] }, { "page": "rrq_worker_config_read", "title": "Read worker configuration", "topics": [ "rrq_worker_config_read" ] }, { "page": "rrq_worker_config_save", "title": "Save worker configuration", "topics": [ "rrq_worker_config_save" ] }, { "page": "rrq_worker_delete_exited", "title": "Clean up exited workers", "topics": [ "rrq_worker_delete_exited" ] }, { "page": "rrq_worker_detect_exited", "title": "Detect exited workers", "topics": [ "rrq_worker_detect_exited" ] }, { "page": "rrq_worker_envir_set", "title": "Set worker environment", "topics": [ "rrq_worker_envir_refresh", "rrq_worker_envir_set" ] }, { "page": "rrq_worker_exists", "title": "Test if a worker exists", "topics": [ "rrq_worker_exists" ] }, { "page": "rrq_worker_info", "title": "Worker information", "topics": [ "rrq_worker_info" ] }, { "page": "rrq_worker_len", "title": "Number of active workers", "topics": [ "rrq_worker_len" ] }, { "page": "rrq_worker_list", "title": "List active workers", "topics": [ "rrq_worker_list" ] }, { "page": "rrq_worker_list_exited", "title": "List exited workers", "topics": [ "rrq_worker_list_exited" ] }, { "page": "rrq_worker_load", "title": "Report on worker load", "topics": [ "rrq_worker_load" ] }, { "page": "rrq_worker_log_tail", "title": "Returns the last (few) elements in the worker log, in a programmatically useful format (see Value).", "topics": [ "rrq_worker_log_tail" ] }, { "page": "rrq_worker_process_log", "title": "Read worker process log", "topics": [ "rrq_worker_process_log" ] }, { "page": "rrq_worker_script", "title": "Write worker runner script", "topics": [ "rrq_worker_script" ] }, { "page": "rrq_worker_spawn", "title": "Spawn a worker", "topics": [ "rrq_worker_spawn" ] }, { "page": "rrq_worker_status", "title": "Worker statuses", "topics": [ "rrq_worker_status" ] }, { "page": "rrq_worker_stop", "title": "Stop workers", "topics": [ "rrq_worker_stop" ] }, { "page": "rrq_worker_task_id", "title": "Current task id for workers", "topics": [ "rrq_worker_task_id" ] }, { "page": "rrq_worker_wait", "title": "Wait for workers", "topics": [ "rrq_worker_wait" ] } ], "_readme": "https://github.com/mrc-ide/rrq/raw/master/README.md", "_rundeps": [ "askpass", "callr", "cli", "crayon", "digest", "docopt", "glue", "hms", "ids", "lifecycle", "logwatch", "openssl", "pkgconfig", "prettyunits", "processx", "progress", "ps", "R6", "redux", "rlang", "storr", "sys", "uuid", "vctrs" ], "_vignettes": [ { "source": "fault-tolerance.Rmd", "filename": "fault-tolerance.html", "title": "Fault tolerance", "engine": "knitr::rmarkdown", "headings": [ "Error handling", "Increasing resilience via separate processes", "Loss of workers", "Retrying tasks", "An example where retrying fixes an error", "Performance considerations", "Deleting tasks that have been retried", "Going further" ], "created": "2023-03-20 14:48:56", "modified": "2024-11-11 15:22:17", "commits": 8 }, { "source": "messages.Rmd", "filename": "messages.html", "title": "messages", "engine": "knitr::rmarkdown", "headings": [ "Messages and responses", "PING", "ECHO", "INFO", "EVAL", "PAUSE / RESUME", "SET_TIMEOUT / GET_TIMEOUT", "Messages that are supported but use via wrappers:" ], "created": "2021-06-09 13:50:16", "modified": "2024-11-11 15:22:17", "commits": 15 }, { "source": "rrq.Rmd", "filename": "rrq.html", "title": "rrq", "engine": "knitr::rmarkdown", "headings": [ "Getting started", "Hello world", "Design", "Running tasks", "Configuring the worker environment", "Scheduling options", "Tasks that depend on other tasks", "Multiple queues", "Running tasks in separate processes", "Coping with memory use", "Orchestrating workers", "Use (and limitations) of spawn", "Start workers on another node, perhaps using a scheduler", "Use docker", "Waiting for workers to appear", "Worker heartbeat", "Getting a Redis server", "Install Redis", "Use Redis on a different machine" ], "created": "2021-06-09 13:50:16", "modified": "2024-11-11 15:22:17", "commits": 21 } ], "_score": 6.306425027550688, "_indexed": false, "_nocasepkg": "rrq", "_universes": [ "vimc" ], "_indexurl": "https://mrc-ide.r-universe.dev/rrq", "_binaries": [ { "r": "4.7.0", "os": "linux", "version": "0.7.23", "date": "2026-05-20T07:38:58.000Z", "distro": "noble", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "f92bebf039b667d80c27a3e4e6ed72543f5b85237a297747cd21e31ef3e84bdc", "status": "success", "check": "OK", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" }, { "r": "4.6.0", "os": "linux", "version": "0.7.23", "date": "2026-05-20T07:38:46.000Z", "distro": "noble", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "ad776991b0756ca55986b83e73b6f98345ee86f0c382d77540ca3ab52a25166f", "status": "success", "check": "OK", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" }, { "r": "4.5.3", "os": "mac", "version": "0.7.23", "date": "2026-05-20T07:38:08.000Z", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "4477876c1bf74aab9cb8056a7f8d79079bcf17deaf691f9fa910b2482112cc39", "status": "success", "check": "OK", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" }, { "r": "4.6.0", "os": "mac", "version": "0.7.23", "date": "2026-05-20T07:38:09.000Z", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "c5f80cacac6ff0400fde167ef366c47bc0029f54fa53b014f9f65687528be322", "status": "success", "check": "OK", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" }, { "r": "4.7.0", "os": "win", "version": "0.7.23", "date": "2026-05-20T07:38:42.000Z", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "2ff1f8c57b9e422c315ea5328ebd29e713256f94e41021954e10bc69fe4a10df", "status": "success", "check": "OK", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" }, { "r": "4.5.3", "os": "win", "version": "0.7.23", "date": "2026-05-20T07:37:49.000Z", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "70f6af4a19bbb0ba6cbbeef3d65a85266ed74d1cd3fb1ae2619339833755826d", "status": "success", "check": "OK", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" }, { "r": "4.6.0", "os": "win", "version": "0.7.23", "date": "2026-05-20T07:37:52.000Z", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "d21f6fa92badf09d1075412e2078874dbf5b6bd12d732e78969c0fe26ff2fd9a", "status": "success", "check": "OK", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" }, { "r": "4.6.0", "os": "wasm", "version": "0.7.23", "date": "2026-06-02T13:49:21.000Z", "commit": "5ff431a3c9d69fb8609d819805f62b470ce40e35", "fileid": "517a4b75255bf699d2e789bfd5e990ec29e16a9c5a98004f126965edead83bd4", "status": "success", "buildurl": "https://github.com/r-universe/vimc/actions/runs/26148261054" } ] }