[Core] update reconciliation metrics and logs (#2931)

Author: danamsalem-ux

CHANGELOG.md

@@ -7,6 +7,15 @@ this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm
 
 <!-- towncrier release notes start -->
 
+## 0.38.13 (2026-03-15)
+
+### Improvements
+
+- Added progress logs in the reconciliation phase: logs are now emitted before fetching current entity state from Port and before the delete diff, showing counts of entities at Port, synced, and to be deleted.
+- Added `success` metric initialization for the reconciliation `syncing` state, ensuring `syncKindsMetrics` won't be stuck on pending state until completion.
+- Changed reconciliation completed/failed metric reporting to use PUT (update existing document) instead of POST (create new document), so the syncing document is updated in-place rather than creating a duplicate.
+
+
 ## 0.38.12 (2026-03-10)
 
 ### Improvements

port_ocean/core/integrations/mixins/sync_raw.py

@@ -738,7 +738,7 @@ async def sort_and_upsert_failed_entities(
 
         except OceanAbortException as ocean_abort:
             logger.info(
-                f"Failed topological sort of failed to upsert entites - trying to upsert unordered {event.entity_topological_sorter.get_entities_count()} entities.",
+                f"Failed topological sort of failed to upsert entities - trying to upsert unordered {event.entity_topological_sorter.get_entities_count()} entities.",
                 failed_topological_sort_entities_count=event.entity_topological_sorter.get_entities_count(),
             )
             if isinstance(ocean_abort.__cause__, CycleError):
@@ -963,10 +963,20 @@ async def _resync_reconciliation(
                         },
                     ],
                 }
+            logger.info(
+                "Fetching current entity state from Port",
+                entities_synced=len(generated_entities),
+            )
             entities_at_port = await ocean.port_client.search_entities(
                 user_agent_type, query
             )
-            entities_to_delete = len(entities_at_port) - len(generated_entities)
+            entities_to_delete = max(0, len(entities_at_port) - len(generated_entities))
+            logger.info(
+                "Calculating diff and deleting stale entities",
+                entities_at_port=len(entities_at_port),
+                entities_synced=len(generated_entities),
+                entities_to_delete=entities_to_delete,
+            )
 
             await self.entities_state_applier.delete_diff(
                 {"before": entities_at_port, "after": generated_entities},
@@ -978,7 +988,7 @@ async def _resync_reconciliation(
                 "Reconciliation phase complete",
                 entities_at_port=len(entities_at_port),
                 entities_synced=len(generated_entities),
-                entities_to_delete=max(0, entities_to_delete),
+                entities_to_delete=entities_to_delete,
             )
 
             logger.info("Resync finished successfully")
@@ -1180,6 +1190,11 @@ async def sync_raw_all(
             else:
                 async with metric_resource_context(MetricResourceKind.RECONCILIATION):
                     ocean.metrics.sync_state = SyncState.SYNCING
+                    ocean.metrics.set_metric(
+                        name=MetricType.SUCCESS_NAME,
+                        labels=[MetricResourceKind.RECONCILIATION, MetricPhase.RESYNC],
+                        value=0,
+                    )
                     await ocean.metrics.send_metrics_to_webhook(
                         kind=MetricResourceKind.RECONCILIATION
                     )
@@ -1199,11 +1214,16 @@ async def sync_raw_all(
                     ocean.metrics.sync_state = (
                         SyncState.COMPLETED if success else SyncState.FAILED
                     )
+                    ocean.metrics.set_metric(
+                        name=MetricType.SUCCESS_NAME,
+                        labels=[MetricResourceKind.RECONCILIATION, MetricPhase.RESYNC],
+                        value=1 if success else 0,
+                    )
                     await ocean.metrics.send_metrics_to_webhook(
                         kind=MetricResourceKind.RECONCILIATION
                     )
-                    await ocean.metrics.report_sync_metrics(
-                        kinds=[MetricResourceKind.RECONCILIATION]
+                    await ocean.metrics.report_kind_sync_metrics(
+                        kind=MetricResourceKind.RECONCILIATION
                     )
 
                 return success

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "port-ocean"
-version = "0.38.12"
+version = "0.38.13"
 description = "Port Ocean is a CLI tool for managing your Port projects."
 readme = "README.md"
 homepage = "https://app.getport.io"