Skip to content

Commit

Permalink
move write phase log down so it is not emitted if the execution bails…
Browse files Browse the repository at this point in the history
… before execute write is called
  • Loading branch information
4meta5 committed Jul 11, 2024
1 parent 9622ae2 commit 253e1a1
Showing 1 changed file with 7 additions and 8 deletions.
15 changes: 7 additions & 8 deletions chronicle/src/tasks/executor.rs
Original file line number Diff line number Diff line change
Expand Up @@ -211,14 +211,6 @@ where
continue;
}

event!(
target: TW_LOG,
parent: &span,
Level::INFO,
task_id,
"Running write phase",
);

let function = match function {
Function::RegisterShard { shard_id } => {
if let Some(gmp_params) = gmp_params {
Expand Down Expand Up @@ -279,6 +271,13 @@ where
},
_ => function,
};
event!(
target: TW_LOG,
parent: &span,
Level::INFO,
task_id,
"Running write phase",
);
self.task_spawner.execute_write(task_id, function)
},
TaskPhase::Read => {
Expand Down

0 comments on commit 253e1a1

Please sign in to comment.