From 2ab69f039c676e1a304206bfa0fd6c6204a1be85 Mon Sep 17 00:00:00 2001 From: Maxime Van Hees Date: Thu, 7 Aug 2025 11:16:47 +0200 Subject: [PATCH] update function definitions --- core/actor/src/lib.rs | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/core/actor/src/lib.rs b/core/actor/src/lib.rs index 693ccb8..19f946a 100644 --- a/core/actor/src/lib.rs +++ b/core/actor/src/lib.rs @@ -12,7 +12,7 @@ const NAMESPACE_PREFIX: &str = "hero:job:"; const BLPOP_TIMEOUT_SECONDS: usize = 5; /// Initialize Redis connection for the actor -pub(crate) async fn initialize_redis_connection( +pub async fn initialize_redis_connection( actor_id: &str, redis_url: &str, ) -> Result> { @@ -33,7 +33,7 @@ pub(crate) async fn initialize_redis_connection( } /// Load job from Redis using Job struct -pub(crate) async fn load_job_from_redis( +pub async fn load_job_from_redis( redis_conn: &mut redis::aio::MultiplexedConnection, job_id: &str, actor_id: &str,