fix: remove Zoho outbound Job flows, reading jobs not supported on Hr…

…Flow Warehouse
Riminder · Nov 26, 2024 · 4af4b82 · 4af4b82
1 parent 77acd9e
commit 4af4b82
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 45 deletions.
diff --git a/src/hrflow_connectors/v2/__init__.py b/src/hrflow_connectors/v2/__init__.py
@@ -1,9 +1,10 @@
 from hrflow_connectors.v2.connectors.bullhorn import Bullhorn
+from hrflow_connectors.v2.connectors.zohorecruit import ZohoRecruit
 from hrflow_connectors.v2.core.connector import (  # noqa: F401
     hrflow_connectors_manifest as hrflow_connectors_manifest,
 )
 from hrflow_connectors.v2.core.documentation import (  # noqa: F401
     hrflow_connectors_docs as hrflow_connectors_docs,
 )
 
-__CONNECTORS__ = [Bullhorn]
+__CONNECTORS__ = [Bullhorn, ZohoRecruit]
diff --git a/src/hrflow_connectors/v2/connectors/zohorecruit/aisles.py b/src/hrflow_connectors/v2/connectors/zohorecruit/aisles.py
@@ -726,25 +726,14 @@ def __delete_records(
         criterias=Criterias(
             create=ReadParameters,
             archive=ReadDeleteParameters,
+            update=ReadParameters,
         ),
         function=merge(
             create=generic_read(module_api_name="JobOpenings", action=Mode.create),
             archive=generic_read_deleted("JobOpenings"),
             update=generic_read(module_api_name="JobOpenings", action=Mode.update),
         ),
     ),
-    write=WriteOperation(
-        criterias=Criterias(
-            create=WriteParameters,
-            update=WriteParameters,
-            archive=WriteDeleteParameters,
-        ),
-        function=merge(
-            create=generic_write("JobOpenings"),
-            update=generic_update("JobOpenings"),
-            archive=generic_delete("JobOpenings"),
-        ),
-    ),
 )
 
 ProfilesAisle = Aisle(
@@ -754,6 +743,7 @@ def __delete_records(
         criterias=Criterias(
             create=ReadParameters,
             archive=ReadDeleteParameters,
+            update=ReadParameters,
         ),
         function=merge(
             create=generic_read(module_api_name="Candidates", action=Mode.create),

diff --git a/src/hrflow_connectors/v2/connectors/zohorecruit/connector.py b/src/hrflow_connectors/v2/connectors/zohorecruit/connector.py
@@ -250,23 +250,6 @@ def format_hrflow_profile_to_zoho(profile: dict) -> dict:
     return zoho_candidate
 
 
-def format_hrflow_job_to_zoho(job: dict) -> dict:
-    zoho_job_opening = dict(
-        Job_Opening_Name=job["name"],
-        Posting_Title=job["name"],
-        Required_Skills=get_zoho_skill_set(job["skills"]),
-        Created_Time=job["created_at"],
-        Modified_Time=job["updated_at"],
-        City=job["location"]["fields"].get("city", None),
-        State=job["location"]["fields"].get("state", None),
-        Country=job["location"]["fields"].get("country", None),
-        Zip_Code=job["location"]["fields"].get("postcode", None),
-        Job_Description=job["summary"],
-        Additional_Info=job["sections"][1]["description"],
-    )
-    return zoho_job_opening
-
-
 def format_archive_in_hrflow(record: dict) -> dict:
     return dict(reference=record["id"])
 
@@ -332,29 +315,14 @@ def format_archive_in_zoho(record: dict) -> dict:
             Direction.inbound,
             format=format_zoho_job_opening_to_hrflow,
         ),
-        Flow(
-            Mode.create,
-            Entity.job,
-            Direction.outbound,
-            format=format_hrflow_job_to_zoho,
-        ),
         Flow(
             Mode.update,
             Entity.job,
             Direction.inbound,
             format=format_zoho_job_opening_to_hrflow,
         ),
-        Flow(
-            Mode.update,
-            Entity.job,
-            Direction.outbound,
-            format=format_hrflow_job_to_zoho,
-        ),
         Flow(
             Mode.archive, Entity.job, Direction.inbound, format=format_archive_in_hrflow
         ),
-        Flow(
-            Mode.archive, Entity.job, Direction.outbound, format=format_archive_in_zoho
-        ),
     ),
 )