s/register_fresh_index/register_fresh_start

pulibrary · Dec 4, 2024 · a16ccd1 · a16ccd1
1 parent 8073b1d
commit a16ccd1
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/lib/dpul_collections/index_metrics_tracker.ex b/lib/dpul_collections/index_metrics_tracker.ex
@@ -28,8 +28,8 @@ defmodule DpulCollections.IndexMetricsTracker do
     {:ok, %{}}
   end
 
-  @spec register_fresh_index(source :: module()) :: term()
-  def register_fresh_index(source) do
+  @spec register_fresh_start(source :: module()) :: term()
+  def register_fresh_start(source) do
     GenServer.call(__MODULE__, {:fresh_index, source})
   end
 

diff --git a/lib/dpul_collections/indexing_pipeline/database_producer.ex b/lib/dpul_collections/indexing_pipeline/database_producer.ex
@@ -65,7 +65,7 @@ defmodule DpulCollections.IndexingPipeline.DatabaseProducer do
       source_module.get_cache_entries_since!(last_queried_marker, total_demand, cache_version)
 
     if last_queried_marker == nil && length(records) > 0 do
-      DpulCollections.IndexMetricsTracker.register_fresh_index(source_module)
+      DpulCollections.IndexMetricsTracker.register_fresh_start(source_module)
     end
 
     new_state =

diff --git a/test/dpul_collections/index_metrics_tracker_test.exs b/test/dpul_collections/index_metrics_tracker_test.exs
@@ -25,7 +25,7 @@ defmodule DpulCollections.IndexMetricsTrackerTest do
         }
       )
 
-      IndexMetricsTracker.register_fresh_index(HydrationProducerSource)
+      IndexMetricsTracker.register_fresh_start(HydrationProducerSource)
       # Send an ack done with acked_count 1
       :telemetry.execute(
         [:database_producer, :ack, :done],