fix: propagate fallible restore publication through server factory adapters
This commit is contained in:
@@ -138,9 +138,9 @@ impl RuntimeWorkerFactory for CapturingFactory {
|
|||||||
worker_ref: &worker_runtime::identity::WorkerRef,
|
worker_ref: &worker_runtime::identity::WorkerRef,
|
||||||
workspace_id: Option<&str>,
|
workspace_id: Option<&str>,
|
||||||
handle: &worker::WorkerHandle,
|
handle: &worker::WorkerHandle,
|
||||||
) {
|
) -> std::result::Result<(), String> {
|
||||||
self.inner
|
self.inner
|
||||||
.activate_restored_controller(worker_ref, workspace_id, handle);
|
.activate_restored_controller(worker_ref, workspace_id, handle)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -1084,9 +1084,9 @@ impl worker_runtime::worker_backend::RuntimeWorkerFactory for RestoreAuthFactory
|
|||||||
worker_ref: &worker_runtime::identity::WorkerRef,
|
worker_ref: &worker_runtime::identity::WorkerRef,
|
||||||
workspace_id: Option<&str>,
|
workspace_id: Option<&str>,
|
||||||
handle: &worker::WorkerHandle,
|
handle: &worker::WorkerHandle,
|
||||||
) {
|
) -> std::result::Result<(), String> {
|
||||||
self.inner
|
self.inner
|
||||||
.activate_restored_controller(worker_ref, workspace_id, handle);
|
.activate_restored_controller(worker_ref, workspace_id, handle)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
@@ -636,9 +636,9 @@ impl worker_runtime::worker_backend::RuntimeWorkerFactory for ConfigCaptureFacto
|
|||||||
worker_ref: &worker_runtime::identity::WorkerRef,
|
worker_ref: &worker_runtime::identity::WorkerRef,
|
||||||
workspace_id: Option<&str>,
|
workspace_id: Option<&str>,
|
||||||
handle: &worker::WorkerHandle,
|
handle: &worker::WorkerHandle,
|
||||||
) {
|
) -> std::result::Result<(), String> {
|
||||||
self.inner
|
self.inner
|
||||||
.activate_restored_controller(worker_ref, workspace_id, handle);
|
.activate_restored_controller(worker_ref, workspace_id, handle)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user