engine: force flush on shutdown to create tasks for pending chunks

Signed-off-by: Wesley Pettit <wppttt@amazon.com>
PettitWesley · Jun 13, 2024 · ed938c2 · ed938c2
1 parent 362aa77
commit ed938c2
Showing 1 changed file with 6 additions and 4 deletions.
diff --git a/src/flb_engine.c b/src/flb_engine.c
@@ -840,9 +840,11 @@ int flb_engine_start(struct flb_config *config)
                             flb_task_running_print(config);
                         }
                         if ((mem_chunks + fs_chunks) > 0) {
-                            flb_info("[engine] Pending chunk count: memory=%d, filesystem=%d",
-                                     mem_chunks, fs_chunks);
+                            flb_info("[engine] Pending chunk count: memory=%d, filesystem=%d; grace_timer=%d",
+                                     mem_chunks, fs_chunks, config->grace);
                         }
+                        /* Create new tasks for pending chunks */
+                        flb_engine_flush(config, NULL);
                         if (config->grace_count < config->grace_input) {
                             flb_engine_exit(config);
                         } else {
@@ -854,8 +856,8 @@ int flb_engine_start(struct flb_config *config)
                             flb_task_running_print(config);
                         }
                         if ((mem_chunks + fs_chunks) > 0) {
-                            flb_info("[engine] Pending chunk count: memory=%d, filesystem=%d",
-                                     mem_chunks, fs_chunks);
+                            flb_info("[engine] pending chunk count: memory=%d, filesystem=%d; grace_timer=%d",
+                                     mem_chunks, fs_chunks, config->grace);
                         }
                         flb_info("[engine] service has stopped (%i pending tasks)",
                                  tasks);