diff --git a/tests/integration/test_workflow.py b/tests/integration/test_workflow.py
index 5d7d02df..e6cffbcf 100644
--- a/tests/integration/test_workflow.py
+++ b/tests/integration/test_workflow.py
@@ -57,7 +57,8 @@ def test_wis2downloader():
         'origin/a/wis2/int-wmo-test/data/core/weather/surface-based-observations/buoy': 2, # noqa
         'origin/a/wis2/int-wmo-test/data/core/weather/surface-based-observations/wind_profiler': 1, # noqa
         'origin/a/wis2/int-wmo-test/data/core/weather/surface-based-observations/ship': 5, # noqa
-        'origin/a/wis2/it-roma_met_centre/data/core/weather/surface-based-observations/synop': 31 # noqa
+        'origin/a/wis2/it-roma_met_centre/data/core/weather/surface-based-observations/synop': 31, # noqa
+        'origin/a/wis2/int-wmo-test/data/core/weather/cap-alerts': 1 # noqa
     }
 
     topic_nfiles_dict_found = {}
@@ -125,7 +126,7 @@ def test_metadata_discovery_publish():
     """Test discovery metadata publishing"""
 
     r = SESSION.get(f'{API_URL}/collections/discovery-metadata/items').json()
-    assert r['numberMatched'] == 9
+    assert r['numberMatched'] == 10
 
     r = SESSION.get(f'{API_URL}/collections/discovery-metadata/items/{ID}').json()  # noqa
 
@@ -291,7 +292,7 @@ def test_message_api():
         'dz-alger_met_centre': 29,
         'ro-rnimh': 50,
         'cd-brazza_met_centre': 15,
-        'int-wmo-test': 11,
+        'int-wmo-test': 12,
         'cn-cma': 11
     }
     for key, value in counts.items():