tests/deamon.r

In okux/qrmarkdown: Job Queue Management For Rmarkdown

test1 <- function()
{
  require(qrmarkdown)

  setup()
  q.ls()

  ii = q.push(code='Sys.sleep(2) ')
  ii = q.push(code='Sys.sleep(2)')
  q.show()

  # single execution for debuging
  deamon(wait=TRUE, timer = 10, wdir = q.wd(), n=2)
  q.wait(ii, timer = 10)

  res <- q.show()

  expect(res$outbox == 2, 'single process a job')
  q.show()

  # concurrent execution
  setup()
  for(i in 1:10 )
    ii = q.push(code='Sys.sleep(2) ')
  deamon(timer = 10, wdir = q.wd(), n=10)

  res <- q.show()
  expect(res$outbox == 10, 'concurrent test completed test')
}

test1()
clean()