Frozen Rush Data Storage

Freezes the Redis data base of an ArchiveAsync to a data.table::data.table(). No further points can be added to the archive but the data can be accessed and analyzed. Useful when the Redis data base is not permanently available. Use the callback bbotk.async_freeze_archive to freeze the archive after the optimization has finished.

S3 Methods

as.data.table(archive)
ArchiveAsync -> data.table::data.table()
Returns a tabular view of all performed function calls of the Objective. The x_domain column is unnested to separate columns.

Super classes

bbotk::Archive -> bbotk::ArchiveAsync -> ArchiveAsyncFrozen

Active bindings

data: (data.table::data.table)
Data table with all finished points.
queued_data: (data.table::data.table)
Data table with all queued points.
running_data: (data.table::data.table)
Data table with all running points.
finished_data: (data.table::data.table)
Data table with all finished points.
failed_data: (data.table::data.table)
Data table with all failed points.
n_queued: (integer(1))
Number of queued points.
n_running: (integer(1))
Number of running points.
n_finished: (integer(1))
Number of finished points.
n_failed: (integer(1))
Number of failed points.
n_evals: (integer(1))
Number of evaluations stored in the archive.

Methods

Public methods

ArchiveAsyncFrozen$new()
ArchiveAsyncFrozen$push_points()
ArchiveAsyncFrozen$pop_point()
ArchiveAsyncFrozen$push_running_point()
ArchiveAsyncFrozen$push_result()
ArchiveAsyncFrozen$push_failed_point()
ArchiveAsyncFrozen$data_with_state()
ArchiveAsyncFrozen$clear()
ArchiveAsyncFrozen$clone()

Inherited methods

Method `new()`

Creates a new instance of this R6 class.

Usage

ArchiveAsyncFrozen$new(archive)

Arguments

archive: (ArchiveAsync)
The archive to freeze.

Method `push_points()`

Push queued points to the archive.

Usage

ArchiveAsyncFrozen$push_points(xss)

Arguments

xss: (list of named list())
List of named lists of point values.

Method `pop_point()`

Pop a point from the queue.

Usage

ArchiveAsyncFrozen$pop_point()

Method `push_running_point()`

Push running point to the archive.

Usage

ArchiveAsyncFrozen$push_running_point(xs, extra = NULL)

Arguments

xs: (named list)
Named list of point values.
extra: (list())
Named list of additional information.

Method `push_result()`

Push result to the archive.

Usage

ArchiveAsyncFrozen$push_result(key, ys, x_domain, extra = NULL)

Arguments

key: (character())
Key of the point.
ys: (list())
Named list of results.
x_domain: (list())
Named list of transformed point values.
extra: (list())
Named list of additional information.

Method `push_failed_point()`

Push failed point to the archive.

Usage

ArchiveAsyncFrozen$push_failed_point(key, message)

Arguments

key: (character())
Key of the point.
message: (character())
Error message.

Method `data_with_state()`

Fetch points with a specific state.

Usage

ArchiveAsyncFrozen$data_with_state(
  fields = c("xs", "ys", "xs_extra", "worker_extra", "ys_extra", "condition"),
  states = c("queued", "running", "finished", "failed"),
  reset_cache = FALSE
)

Arguments

fields: (character())
Fields to fetch. Defaults to c("xs", "ys", "xs_extra", "worker_extra", "ys_extra").
states: (character())
States of the tasks to be fetched. Defaults to c("queued", "running", "finished", "failed").
reset_cache: (logical(1))
Whether to reset the cache of the finished points.

Method `clear()`

Clear all evaluation results from archive.

Usage

ArchiveAsyncFrozen$clear()

Method `clone()`

The objects of this class are cloneable with this method.

Usage

ArchiveAsyncFrozen$clone(deep = FALSE)

Arguments

deep: Whether to make a deep clone.

Examples

# example only runs if a Redis server is available
if (mlr3misc::require_namespaces(c("rush", "redux", "mirai"), quietly = TRUE) &&
  redux::redis_available()) {
# define the objective function
fun = function(xs) {
  list(y = - (xs[[1]] - 2)^2 - (xs[[2]] + 3)^2 + 10)
}

# set domain
domain = ps(
  x1 = p_dbl(-10, 10),
  x2 = p_dbl(-5, 5)
)

# set codomain
codomain = ps(
  y = p_dbl(tags = "maximize")
)

# create objective
objective = ObjectiveRFun$new(
  fun = fun,
  domain = domain,
  codomain = codomain,
  properties = "deterministic"
)

# start workers
rush::rush_plan(worker_type = "remote")
mirai::daemons(1)

# initialize instance
instance = oi_async(
  objective = objective,
  terminator = trm("evals", n_evals = 20),
  callback = clbk("bbotk.async_freeze_archive")
)

# load optimizer
optimizer = opt("async_random_search")

# trigger optimization
optimizer$optimize(instance)

# frozen archive
instance$archive

# best performing configuration
instance$archive$best()

# covert to data.table
as.data.table(instance$archive)
}
#>        state         x1           x2            y        timestamp_xs   pid
#>       <char>      <num>        <num>        <num>              <POSc> <int>
#>  1: finished  0.7355865  4.436809312  -46.9048744 2026-02-18 13:47:01  7734
#>  2: finished -5.2465150  1.685353492  -64.4645163 2026-02-18 13:47:01  7734
#>  3: finished -1.6100269  1.692733854  -25.0540453 2026-02-18 13:47:01  7734
#>  4: finished -9.6485851  2.074896538 -151.4441090 2026-02-18 13:47:01  7734
#>  5: finished  9.1534135  0.636737862  -54.3971877 2026-02-18 13:47:01  7734
#>  6: finished -0.9507994 -4.878603549   -2.2363683 2026-02-18 13:47:01  7734
#>  7: finished  2.7997505 -1.921276769    8.1967553 2026-02-18 13:47:01  7734
#>  8: finished  7.9367603  3.130829856  -62.8321976 2026-02-18 13:47:01  7734
#>  9: finished -5.3535132  0.132857377  -53.8889510 2026-02-18 13:47:01  7734
#> 10: finished -1.1703927  1.581480915  -21.0413571 2026-02-18 13:47:01  7734
#> 11: finished  5.5692991  1.671339287  -24.5613067 2026-02-18 13:47:01  7734
#> 12: finished  9.4659255 -4.325706593  -47.4975413 2026-02-18 13:47:01  7734
#> 13: finished -4.5022012 -3.621611151  -32.6650205 2026-02-18 13:47:01  7734
#> 14: finished  6.4919932  0.400897277  -21.7441056 2026-02-18 13:47:01  7734
#> 15: finished -1.5261497 -0.002130552  -11.4209531 2026-02-18 13:47:01  7734
#> 16: finished  5.2346110 -2.546360991   -0.6684964 2026-02-18 13:47:01  7734
#> 17: finished -8.1469277 -2.532682236  -93.1785285 2026-02-18 13:47:01  7734
#> 18: finished  7.9586287 -3.273955223  -25.5803070 2026-02-18 13:47:01  7734
#> 19: finished  5.3650967 -2.241232399   -1.8996043 2026-02-18 13:47:01  7734
#> 20: finished  4.8743111  3.778382706  -44.2081363 2026-02-18 13:47:01  7734
#>        state         x1           x2            y        timestamp_xs   pid
#>       <char>      <num>        <num>        <num>              <POSc> <int>
#>            worker_id        timestamp_ys                                 keys
#>               <char>              <POSc>                               <char>
#>  1: limestone_drever 2026-02-18 13:47:01 bfcb5a5a-4d46-4ff6-a43d-3e32314c8788
#>  2: limestone_drever 2026-02-18 13:47:01 81100f17-6621-4800-a502-4bf9a58dea8b
#>  3: limestone_drever 2026-02-18 13:47:01 f760967f-2c49-4ef9-9c83-23ce101748f8
#>  4: limestone_drever 2026-02-18 13:47:01 29e093b2-e2f7-47e9-8750-5275871d88f3
#>  5: limestone_drever 2026-02-18 13:47:01 018bde6d-b5d4-4f90-b621-77f9ba8fd855
#>  6: limestone_drever 2026-02-18 13:47:01 04e47666-6b51-4b6a-a808-771e9ded6f85
#>  7: limestone_drever 2026-02-18 13:47:01 896e03c6-a474-482d-abc2-941bdf5d09de
#>  8: limestone_drever 2026-02-18 13:47:01 5cdd2721-d5a3-4571-b51a-9db01b5a8e2c
#>  9: limestone_drever 2026-02-18 13:47:01 2d8d6fed-4967-4b92-a318-d8cb77552cfb
#> 10: limestone_drever 2026-02-18 13:47:01 2d03bdda-be7e-4c40-8826-cf3f2ceef9f1
#> 11: limestone_drever 2026-02-18 13:47:01 86266287-6bd8-4ef2-a346-d9a09af0f36e
#> 12: limestone_drever 2026-02-18 13:47:01 34a48f2e-d45f-4625-bbfa-5601a3c68b49
#> 13: limestone_drever 2026-02-18 13:47:01 c9d4caa1-9436-4bb0-8c35-a73cf105438c
#> 14: limestone_drever 2026-02-18 13:47:01 78f52991-105f-41da-a9c8-8c1fc7b556a7
#> 15: limestone_drever 2026-02-18 13:47:01 e52e07b6-91c0-4e4d-b6a6-9ad8c054d26f
#> 16: limestone_drever 2026-02-18 13:47:01 e4a478f5-4d2a-4421-894d-333ffc4b06a7
#> 17: limestone_drever 2026-02-18 13:47:01 aed071ce-44a3-43fa-b234-0c72baaabce3
#> 18: limestone_drever 2026-02-18 13:47:01 a799d9b9-3cb4-4b10-aed4-9f0e578a3f37
#> 19: limestone_drever 2026-02-18 13:47:01 1bbc2159-e6ff-4dce-b5c5-b07fbe9d97c9
#> 20: limestone_drever 2026-02-18 13:47:01 93a1c41c-fbd5-4711-a04e-9578299ee921
#>            worker_id        timestamp_ys                                 keys
#>               <char>              <POSc>                               <char>
#>     x_domain_x1  x_domain_x2
#>           <num>        <num>
#>  1:   0.7355865  4.436809312
#>  2:  -5.2465150  1.685353492
#>  3:  -1.6100269  1.692733854
#>  4:  -9.6485851  2.074896538
#>  5:   9.1534135  0.636737862
#>  6:  -0.9507994 -4.878603549
#>  7:   2.7997505 -1.921276769
#>  8:   7.9367603  3.130829856
#>  9:  -5.3535132  0.132857377
#> 10:  -1.1703927  1.581480915
#> 11:   5.5692991  1.671339287
#> 12:   9.4659255 -4.325706593
#> 13:  -4.5022012 -3.621611151
#> 14:   6.4919932  0.400897277
#> 15:  -1.5261497 -0.002130552
#> 16:   5.2346110 -2.546360991
#> 17:  -8.1469277 -2.532682236
#> 18:   7.9586287 -3.273955223
#> 19:   5.3650967 -2.241232399
#> 20:   4.8743111  3.778382706
#>     x_domain_x1  x_domain_x2
#>           <num>        <num>

S3 Methods

See also

Super classes

Active bindings

Methods

Public methods

Method new()

Usage

Arguments

Method push_points()

Usage

Arguments

Method pop_point()

Usage

Method push_running_point()

Usage

Arguments

Method push_result()

Usage

Arguments

Method push_failed_point()

Usage

Arguments

Method data_with_state()

Usage

Arguments

Method clear()

Usage

Method clone()

Usage

Arguments

Examples

Method `new()`

Method `push_points()`

Method `pop_point()`

Method `push_running_point()`

Method `push_result()`

Method `push_failed_point()`

Method `data_with_state()`

Method `clear()`

Method `clone()`