Port 7003 ocean failure in the entity processing is failing the resync (

#408)

# Description

What - A failure in the entity processing step might fail the whole
resync
Why - The error handling was moved
How - Changed the way the entity processor handled tasks

## Type of change

- [X] Bug fix (non-breaking change which fixes an issue)

CHANGELOG.md

@@ -7,6 +7,14 @@ this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0.htm
 
 <!-- towncrier release notes start -->
 
+## 0.5.4 (2024-03-03)
+
+
+### Bug Fixes
+
+- Fixed an issue where a failure in the entity processing step might fail the whole resync (#1)
+
+
 ## 0.5.3 (2024-03-03)
 
 

port_ocean/core/handlers/entity_processor/jq_entity_processor.py

@@ -1,6 +1,5 @@
 import asyncio
 import functools
-from asyncio import TaskGroup
 from functools import lru_cache
 from typing import Any
 
@@ -51,14 +50,13 @@ async def _search_as_object(
         self, data: dict[str, Any], obj: dict[str, Any]
     ) -> dict[str, Any | None]:
         search_tasks = {}
-        async with TaskGroup() as tg:
-            for key, value in obj.items():
-                if isinstance(value, dict):
-                    search_tasks[key] = tg.create_task(
-                        self._search_as_object(data, value)
-                    )
-                else:
-                    search_tasks[key] = tg.create_task(self._search(data, value))
+        for key, value in obj.items():
+            if isinstance(value, dict):
+                search_tasks[key] = asyncio.create_task(
+                    self._search_as_object(data, value)
+                )
+            else:
+                search_tasks[key] = asyncio.create_task(self._search(data, value))
 
         result: dict[str, Any | None] = {}
         for key, task in search_tasks.items():

pyproject.toml

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