Merge pull request #336 from werf/fix-not-saving-logs-for-sts-and-ds

fix(dynamic-tracker): not saving logs for STS and DS
werf · Feb 7, 2024 · c1febe1 · c1febe1
2 parents d647339 + d064632
commit c1febe1
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/pkg/trackers/dyntracker/dynamic_readiness_tracker.go b/pkg/trackers/dyntracker/dynamic_readiness_tracker.go
@@ -432,7 +432,7 @@ func (t *DynamicReadinessTracker) trackStatefulSet(ctx context.Context, tracker
 		case logChunk := <-tracker.PodLogChunk:
 			t.taskState.RTransaction(func(ts *statestore.ReadinessTaskState) {
 				t.logStore.RWTransaction(func(ls *logstore.LogStore) {
-					t.handleReplicaSetPodLogChunk(logChunk, ls, ts)
+					t.handlePodLogChunk(logChunk.PodLogChunk, ls, ts)
 				})
 			})
 		case msg := <-tracker.EventMsg:
@@ -551,7 +551,7 @@ func (t *DynamicReadinessTracker) trackDaemonSet(ctx context.Context, tracker *d
 		case logChunk := <-tracker.PodLogChunk:
 			t.taskState.RTransaction(func(ts *statestore.ReadinessTaskState) {
 				t.logStore.RWTransaction(func(ls *logstore.LogStore) {
-					t.handleReplicaSetPodLogChunk(logChunk, ls, ts)
+					t.handlePodLogChunk(logChunk.PodLogChunk, ls, ts)
 				})
 			})
 		case msg := <-tracker.EventMsg: