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 = "mirai")
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
#>       <char>       <num>       <num>       <num>              <POSc>
#>  1: finished  0.79964108  4.44173718  -46.820314 2026-04-22 10:04:14
#>  2: finished  1.97171934  0.98977706   -5.919121 2026-04-22 10:04:14
#>  3: finished -8.74678495  2.85974125 -139.829954 2026-04-22 10:04:14
#>  4: finished -8.86620125 -0.52683197 -114.190890 2026-04-22 10:04:14
#>  5: finished  0.07174052  2.66149936  -25.770760 2026-04-22 10:04:14
#>  6: finished -7.51773958 -3.62287586  -80.975341 2026-04-22 10:04:14
#>  7: finished  5.70333065 -4.08089324   -4.882988 2026-04-22 10:04:14
#>  8: finished -6.10767685  3.07812258  -92.677998 2026-04-22 10:04:14
#>  9: finished  9.84218962  4.26953198 -104.346033 2026-04-22 10:04:14
#> 10: finished -9.43527839  3.90120726 -168.392253 2026-04-22 10:04:14
#> 11: finished  7.50436097 -0.05695712  -28.959491 2026-04-22 10:04:14
#> 12: finished -0.84870267 -1.03129050   -1.990924 2026-04-22 10:04:14
#> 13: finished -0.03656525  0.22023930   -4.517539 2026-04-22 10:04:14
#> 14: finished -8.26350117  0.25491344 -105.933918 2026-04-22 10:04:14
#> 15: finished -2.40412588 -0.01124492  -18.328982 2026-04-22 10:04:14
#> 16: finished  2.25513226  4.70309719  -49.402799 2026-04-22 10:04:14
#> 17: finished -6.33460185 -3.98131188  -60.428561 2026-04-22 10:04:14
#> 18: finished -7.94145157 -0.13848943  -97.020702 2026-04-22 10:04:14
#> 19: finished -9.00099977  2.14240782 -137.466354 2026-04-22 10:04:14
#> 20: finished -5.83602346 -2.01183452  -52.379735 2026-04-22 10:04:14
#>        state          x1          x2           y        timestamp_xs
#>       <char>       <num>       <num>       <num>              <POSc>
#>                             worker_id        timestamp_ys
#>                                <char>              <POSc>
#>  1: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  2: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  3: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  4: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  5: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  6: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  7: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  8: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>  9: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 10: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 11: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 12: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 13: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 14: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 15: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 16: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 17: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 18: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 19: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#> 20: artsycraftsy_easteuropeanshepherd 2026-04-22 10:04:14
#>                             worker_id        timestamp_ys
#>                                <char>              <POSc>
#>                                     keys x_domain_x1 x_domain_x2
#>                                   <char>       <num>       <num>
#>  1: 1d23d8bc-7921-4da0-8484-c6171cd8bfbd  0.79964108  4.44173718
#>  2: 134d5d1b-dd56-43cf-a4ba-4b636e9a4b01  1.97171934  0.98977706
#>  3: 4c894c2b-b676-47d5-ac1c-ec3728533d8e -8.74678495  2.85974125
#>  4: 7c4ec655-dc23-4c80-9652-c44ec4065073 -8.86620125 -0.52683197
#>  5: a0db09dd-6008-4e45-b5cf-52f4174713e1  0.07174052  2.66149936
#>  6: 1b905fa7-b4ff-4bb0-aa56-111d2b3b5fe2 -7.51773958 -3.62287586
#>  7: 245836ca-725e-4907-972c-ed5ee0e64a63  5.70333065 -4.08089324
#>  8: 2fe60f78-e6f3-4813-ae03-700f9a13a35f -6.10767685  3.07812258
#>  9: 866ad660-c5e4-41d1-a2cd-37c760927fb0  9.84218962  4.26953198
#> 10: d6d4edae-27bb-4160-8a7b-45abc2d95b4b -9.43527839  3.90120726
#> 11: 5281f82b-f160-42a3-ab4a-fa8a0c9fb9b1  7.50436097 -0.05695712
#> 12: 49954b92-af4b-4dd1-abd8-46c30886b2e3 -0.84870267 -1.03129050
#> 13: 9d0d6b92-8589-4889-b87a-765d8dce988a -0.03656525  0.22023930
#> 14: fe0528b9-7b94-4b43-8881-11126e27924d -8.26350117  0.25491344
#> 15: 30e7dd48-b259-4469-979c-dc31c0d58e91 -2.40412588 -0.01124492
#> 16: f5cb5850-751e-4409-9e24-b35852b97910  2.25513226  4.70309719
#> 17: 10abecf9-6499-4dbe-9ddf-89c4f1ff1aec -6.33460185 -3.98131188
#> 18: a0a07223-1b1d-4306-8b72-275d0c2851d3 -7.94145157 -0.13848943
#> 19: 7efe1a39-9cd5-4e6c-8f85-408b20213a53 -9.00099977  2.14240782
#> 20: d837d113-a742-4725-a03f-f6975a0f5f8b -5.83602346 -2.01183452
#>                                     keys x_domain_x1 x_domain_x2
#>                                   <char>       <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()`