BE: Spilt integration tests and renamed migration

Author: tushortz

…ique_if_force_write_is_false_and_more.py …ints_for_timeseries_and_headline_data.pymetrics/data/migrations/0041_remove_apitimeseries_the_apitimeseries_record_should_be_unique_if_force_write_is_false_and_more.py renamed to metrics/data/migrations/0041_add_embargo_to_unique_field_contraints_for_timeseries_and_headline_data.py metrics/data/migrations/0041_remove_apitimeseries_the_apitimeseries_record_should_be_unique_if_force_write_is_false_and_more.py renamed to metrics/data/migrations/0041_add_embargo_to_unique_field_contraints_for_timeseries_and_headline_data.py

@@ -178,61 +178,40 @@ def test_creates_api_time_series_from_data(
         )
 
     @pytest.mark.django_db
-    def test_reingests_with_updated_embargo_and_later_refresh_date(
+    def test_updates_api_timeseries_embargo_date(
         self,
-        example_headline_data: type_hints.INCOMING_DATA_TYPE,
         example_time_series_data: type_hints.INCOMING_DATA_TYPE,
     ):
         """
-        Given headline and time series data ingested once
+        Given time series data ingested once
         When the same data is ingested again with a later refresh date
             and an updated embargo timestamp
-        Then the latest records for CoreHeadline, CoreTimeSeries, and APITimeSeries
+        Then the latest records for CoreTimeSeries and APITimeSeries
             reflect the updated embargo timestamps
         """
 
         # Before ingestion
-        assert CoreHeadline.objects.all().count() == 0
         assert CoreTimeSeries.objects.all().count() == 0
         assert APITimeSeries.objects.all().count() == 0
 
         # Given
-        initial_headline_data = copy.deepcopy(example_headline_data)
         initial_timeseries_data = copy.deepcopy(example_time_series_data)
-        updated_headline_data = copy.deepcopy(initial_headline_data)
         updated_timeseries_data = copy.deepcopy(initial_timeseries_data)
 
         # When
-        data_ingester(data=initial_headline_data)
         data_ingester(data=initial_timeseries_data)
 
         # Reingest with updated embargo and later refresh date
-        updated_headline_refresh_date = "2023-11-10"
         updated_timeseries_refresh_date = "2023-11-21"
-        updated_headline_embargo = "2023-11-18 08:00:00"
         updated_timeseries_embargo = "2023-11-19 09:15:00"
 
-        updated_headline_data["refresh_date"] = updated_headline_refresh_date
-        for record in updated_headline_data["data"]:
-            record["embargo"] = updated_headline_embargo
-
         updated_timeseries_data["refresh_date"] = updated_timeseries_refresh_date
         for record in updated_timeseries_data["time_series"]:
             record["embargo"] = updated_timeseries_embargo
 
-        data_ingester(data=updated_headline_data)
         data_ingester(data=updated_timeseries_data)
 
         # Then
-        updated_headlines = CoreHeadline.objects.filter(
-            refresh_date__date=updated_headline_refresh_date
-        )
-        assert len(updated_headline_data["data"]) == 2
-        for record in updated_headlines:
-            assert (
-                record.embargo.strftime("%Y-%m-%d %H:%M:%S") == updated_headline_embargo
-            )
-
         updated_core_timeseries = CoreTimeSeries.objects.filter(
             refresh_date__date=updated_timeseries_refresh_date
         )
@@ -254,3 +233,46 @@ def test_reingests_with_updated_embargo_and_later_refresh_date(
                 record.embargo.strftime("%Y-%m-%d %H:%M:%S")
                 == updated_timeseries_embargo
             )
+
+    @pytest.mark.django_db
+    def test_updates_api_coreheadline_embargo_date(
+        self,
+        example_headline_data: type_hints.INCOMING_DATA_TYPE,
+    ):
+        """
+        Given headline data ingested once
+        When the same data is ingested again with a later refresh date
+            and an updated embargo timestamp
+        Then the latest record for CoreHeadline
+            reflect the updated embargo timestamps
+        """
+
+        # Before ingestion
+        assert CoreHeadline.objects.all().count() == 0
+
+        # Given
+        initial_headline_data = copy.deepcopy(example_headline_data)
+        updated_headline_data = copy.deepcopy(initial_headline_data)
+
+        # When
+        data_ingester(data=initial_headline_data)
+
+        # Reingest with updated embargo and later refresh date
+        updated_headline_refresh_date = "2023-11-21"
+        updated_headline_embargo = "2023-11-18 08:00:00"
+
+        updated_headline_data["refresh_date"] = updated_headline_refresh_date
+        for record in updated_headline_data["data"]:
+            record["embargo"] = updated_headline_embargo
+
+        data_ingester(data=updated_headline_data)
+
+        # Then
+        updated_headlines = CoreHeadline.objects.filter(
+            refresh_date__date=updated_headline_refresh_date
+        )
+        assert len(updated_headline_data["data"]) == 2
+        for record in updated_headlines:
+            assert (
+                record.embargo.strftime("%Y-%m-%d %H:%M:%S") == updated_headline_embargo
+            )