Skip to content

Commit 9dadee2

Browse files
committed
Log out the data before and after setting socket.data.requiresCheckpointResumeWithMessage
1 parent 0efed14 commit 9dadee2

File tree

1 file changed

+15
-3
lines changed

1 file changed

+15
-3
lines changed

apps/coordinator/src/index.ts

+15-3
Original file line numberDiff line numberDiff line change
@@ -835,10 +835,16 @@ class TaskCoordinator {
835835
return;
836836
}
837837

838+
logger.log("WAIT_FOR_TASK checkpoint created", {
839+
checkpoint,
840+
socketData: socket.data,
841+
});
842+
838843
//setting this means we can only resume from a checkpoint
839844
socket.data.requiresCheckpointResumeWithMessage = `location:${checkpoint.location}-docker:${checkpoint.docker}`;
840845
logger.log("WAIT_FOR_TASK set requiresCheckpointResumeWithMessage", {
841-
requiresCheckpointResumeWithMessage: socket.data.requiresCheckpointResumeWithMessage,
846+
checkpoint,
847+
socketData: socket.data,
842848
});
843849

844850
const ack = await this.#platformSocket?.sendWithAck("CHECKPOINT_CREATED", {
@@ -912,10 +918,16 @@ class TaskCoordinator {
912918
return;
913919
}
914920

921+
logger.log("WAIT_FOR_BATCH checkpoint created", {
922+
checkpoint,
923+
socketData: socket.data,
924+
});
925+
915926
//setting this means we can only resume from a checkpoint
916927
socket.data.requiresCheckpointResumeWithMessage = `location:${checkpoint.location}-docker:${checkpoint.docker}`;
917-
logger.log("WAIT_FOR_BATCH set requiresCheckpointResumeWithMessage", {
918-
requiresCheckpointResumeWithMessage: socket.data.requiresCheckpointResumeWithMessage,
928+
logger.log("WAIT_FOR_BATCH set checkpoint", {
929+
checkpoint,
930+
socketData: socket.data,
919931
});
920932

921933
const ack = await this.#platformSocket?.sendWithAck("CHECKPOINT_CREATED", {

0 commit comments

Comments
 (0)