Skip to content
This repository has been archived by the owner on Dec 20, 2023. It is now read-only.

Commit

Permalink
Update to use new ids
Browse files Browse the repository at this point in the history
  • Loading branch information
richfitz committed May 12, 2016
1 parent 24cc659 commit c7041b4
Show file tree
Hide file tree
Showing 5 changed files with 5 additions and 5 deletions.
1 change: 1 addition & 0 deletions .travis.yml
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,7 @@ before_install:
install:
- ./travis-tool.sh install_deps
- ./travis-tool.sh install_aptget libhiredis-dev
- ./travis-tool.sh install_aptget libcurl4-openssl-dev
- ./travis-tool.sh github_package gaborcsardi/progress
- ./travis-tool.sh github_package ropensci/RedisAPI
- ./travis-tool.sh github_package richfitz/redux
Expand Down
2 changes: 1 addition & 1 deletion DESCRIPTION
Original file line number Diff line number Diff line change
Expand Up @@ -15,7 +15,7 @@ Imports:
crayon,
digest,
docopt,
ids,
ids (>= 0.0.2),
progress,
redux (>= 0.3.0),
storr (>= 1.0.0)
Expand Down
2 changes: 1 addition & 1 deletion R/common.R
Original file line number Diff line number Diff line change
Expand Up @@ -80,7 +80,7 @@ rrqueue_key_task_complete <- function(queue, task_id) {
sprintf("%s:tasks:%s:complete", queue, task_id)
}
rrqueue_key_worker_alive <- function(queue) {
sprintf("%s:workers:alive:%s", queue, ids::aa(1)())
sprintf("%s:workers:alive:%s", queue, ids::adjective_animal())
}

## TODO: come up with a way of scheduling object deletion. Things
Expand Down
3 changes: 1 addition & 2 deletions R/utils.R
Original file line number Diff line number Diff line change
Expand Up @@ -212,10 +212,9 @@ match_value <- function(arg, choices, name=deparse(substitute(arg))) {
arg
}

##' @importFrom ids aa
create_group <- function(group, verbose) {
if (is.null(group)) {
group <- ids::aa(1)()
group <- ids::adjective_animal()
if (verbose) {
message(sprintf("Creating group: '%s'", group))
}
Expand Down
2 changes: 1 addition & 1 deletion tests/testthat/myfuns.R
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,6 @@ failure <- function(controlled) {
## This is a blocking call that skips the R interrupt loop; we won't
## listen for SIGINT during this and the stop request will fail.
block <- function(n) {
key <- ids::aa(1)(1)
key <- ids::adjective_animal()
rrqueue:::redis_connection(NULL)$BLPOP(key, n)
}

0 comments on commit c7041b4

Please sign in to comment.