Skip to content

Commit

Permalink
more log fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
yaelibarg committed Jan 16, 2025
1 parent 6299d35 commit ba4d1d2
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions port_ocean/core/integrations/mixins/sync_raw.py
Original file line number Diff line number Diff line change
Expand Up @@ -206,12 +206,12 @@ async def _register_resource_raw(
changed_entities, user_agent_type
)
else:
logger.info("no changed entities, not upserting", total_entities=len(objects_diff[0].entity_selector_diff.passed))
logger.info("Entities in batch didn't changed since last sync, skipping", total_entities=len(objects_diff[0].entity_selector_diff.passed))

modified_objects = [ocean.port_client._reduce_entity(entity) for entity in objects_diff[0].entity_selector_diff.passed]

except Exception as e:
logger.warning(f"Failed to map entities with Port, falling back to upserting all entities: {str(e)}")
logger.warning(f"Failed to resolve batch entities with Port, falling back to upserting all entities: {str(e)}")
modified_objects = await self.entities_state_applier.upsert(
objects_diff[0].entity_selector_diff.passed, user_agent_type
)
Expand Down

0 comments on commit ba4d1d2

Please sign in to comment.