feat: update LoggerRecipe with nb loaded items since last flush

bpolaszek · Dec 5, 2023 · 9260690 · 9260690
1 parent 4531cbc
commit 9260690
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/src/Recipe/LoggerRecipe.php b/src/Recipe/LoggerRecipe.php
@@ -127,9 +127,9 @@ public function decorate(EtlExecutor $executor): EtlExecutor
             ->onFlush(
                 fn (FlushEvent $event) => $this->log(
                     $event,
-                    $event->early ? 'Flushing items (early)...' : 'Flushing items...',
+                    $event->early ? 'Flushing {nb} items (early)...' : 'Flushing {nb} items...',
                     [
-                        'key' => $event->state->currentItemKey,
+                        'nb' => $event->state->nbLoadedItemsSinceLastFlush,
                         'state' => $event->state,
                     ],
                 ),

diff --git a/tests/Unit/Recipe/LoggerRecipeTest.php b/tests/Unit/Recipe/LoggerRecipeTest.php
@@ -30,12 +30,12 @@
         fn ($record) => $record->message->toContain('Extracting item')->and($record->level->toBe(Level::Debug)),
         fn ($record) => $record->message->toContain('Transformed item')->and($record->level->toBe(Level::Debug)),
         fn ($record) => $record->message->toContain('Loaded item')->and($record->level->toBe(Level::Debug)),
-        fn ($record) => $record->message->toContain('Flushing items (early)...')->and($record->level->toBe(Level::Info)),
+        fn ($record) => $record->message->toContain('Flushing {nb} items (early)...')->and($record->level->toBe(Level::Info)),
         fn ($record) => $record->message->toContain('Extracting item')->and($record->level->toBe(Level::Debug)),
         fn ($record) => $record->message->toContain('Transformed item')->and($record->level->toBe(Level::Debug)),
         fn ($record) => $record->message->toContain('Loaded item')->and($record->level->toBe(Level::Debug)),
-        fn ($record) => $record->message->toContain('Flushing items (early)...')->and($record->level->toBe(Level::Info)),
-        fn ($record) => $record->message->toContain('Flushing items...')->and($record->level->toBe(Level::Info)),
+        fn ($record) => $record->message->toContain('Flushing {nb} items (early)...')->and($record->level->toBe(Level::Info)),
+        fn ($record) => $record->message->toContain('Flushing {nb} items...')->and($record->level->toBe(Level::Info)),
         fn ($record) => $record->message->toContain('ETL complete.')->and($record->level->toBe(Level::Info)),
     );
 });