Skip to content

Commit b647aba

Browse files
Implement BatchtoolsLocalFutureBackend
1 parent c027bb9 commit b647aba

17 files changed

+664
-127
lines changed

DESCRIPTION

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,9 +1,9 @@
11
Package: future.batchtools
2-
Version: 0.12.1-9006
2+
Version: 0.12.1-9100
33
Depends:
44
R (>= 3.2.0),
55
parallelly,
6-
future (>= 1.31.0)
6+
future (>= 1.34.0-9300)
77
Imports:
88
batchtools (>= 0.9.16),
99
utils
@@ -30,5 +30,6 @@ License: LGPL (>= 2.1)
3030
LazyLoad: TRUE
3131
URL: https://future.batchtools.futureverse.org, https://github.com/futureverse/future.batchtools
3232
BugReports: https://github.com/futureverse/future.batchtools/issues
33+
Encoding: UTF-8
3334
RoxygenNote: 7.3.2
3435
Roxygen: list(markdown = TRUE)

NAMESPACE

Lines changed: 10 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,11 +2,15 @@
22

33
S3method(add_finalizer,BatchtoolsFuture)
44
S3method(delete,BatchtoolsFuture)
5+
S3method(launchFuture,BatchtoolsFutureBackend)
6+
S3method(listFutures,BatchtoolsLocalFutureBackend)
57
S3method(loggedError,BatchtoolsFuture)
68
S3method(loggedOutput,BatchtoolsFuture)
9+
S3method(nbrOfFreeWorkers,BatchtoolsLocalFutureBackend)
710
S3method(nbrOfFreeWorkers,batchtools)
811
S3method(nbrOfFreeWorkers,batchtools_multiprocess)
912
S3method(nbrOfFreeWorkers,batchtools_uniprocess)
13+
S3method(nbrOfWorkers,BatchtoolsLocalFutureBackend)
1014
S3method(nbrOfWorkers,batchtools)
1115
S3method(nbrOfWorkers,batchtools_multicore)
1216
S3method(nbrOfWorkers,batchtools_uniprocess)
@@ -27,9 +31,11 @@ export("%resources%")
2731
export(BatchtoolsBashFuture)
2832
export(BatchtoolsCustomFuture)
2933
export(BatchtoolsFuture)
34+
export(BatchtoolsFutureBackend)
3035
export(BatchtoolsFutureError)
3136
export(BatchtoolsInteractiveFuture)
3237
export(BatchtoolsLocalFuture)
38+
export(BatchtoolsLocalFutureBackend)
3339
export(BatchtoolsLsfFuture)
3440
export(BatchtoolsMulticoreFuture)
3541
export(BatchtoolsMultiprocessFuture)
@@ -82,16 +88,20 @@ importFrom(batchtools,setJobNames)
8288
importFrom(batchtools,submitJobs)
8389
importFrom(batchtools,waitForJobs)
8490
importFrom(future,Future)
91+
importFrom(future,FutureBackend)
8592
importFrom(future,FutureError)
8693
importFrom(future,getExpression)
8794
importFrom(future,getGlobalsAndPackages)
95+
importFrom(future,launchFuture)
96+
importFrom(future,listFutures)
8897
importFrom(future,nbrOfFreeWorkers)
8998
importFrom(future,nbrOfWorkers)
9099
importFrom(future,plan)
91100
importFrom(future,resolved)
92101
importFrom(future,result)
93102
importFrom(future,run)
94103
importFrom(future,tweak)
104+
importFrom(future,withPlan)
95105
importFrom(parallelly,availableCores)
96106
importFrom(parallelly,availableWorkers)
97107
importFrom(utils,capture.output)

R/BatchtoolsCustomFuture-class.R

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -23,3 +23,4 @@ BatchtoolsBashFuture <- function(expr = NULL, substitute = TRUE, envir = parent.
2323

2424
future
2525
}
26+

0 commit comments

Comments
 (0)