From 84b5803317c0d893fdbeeedcde4ff196e8357d2f Mon Sep 17 00:00:00 2001 From: Abdellahitech Date: Tue, 19 Mar 2024 16:59:53 +0000 Subject: [PATCH] fix: add job-number to jobology and meteojob flux --- README.md | 4 ++-- src/hrflow_connectors/connectors/jobology/connector.py | 6 +++++- .../connectors/jobology/docs/catch_profile.md | 2 +- src/hrflow_connectors/connectors/meteojob/connector.py | 6 +++++- .../connectors/meteojob/docs/catch_profile.md | 2 +- 5 files changed, 14 insertions(+), 6 deletions(-) diff --git a/README.md b/README.md index 0c6dceb50..7fc9c711c 100644 --- a/README.md +++ b/README.md @@ -62,7 +62,7 @@ We invite developers to join us in our mission to bring AI and data integration | **Comeet** | ATS | 🎯 | | | | | | | | **Cornerstone OnDemand** | ATS | 🎯 | | | | | | | | **Crosstalent** | ATS | :hourglass: | *19/01/2022* | | | | | | -| [**DigitalRecruiters**](./src/hrflow_connectors/connectors/digitalrecruiters/README.md) | ATS | :white_check_mark: | *17/08/2023* | *23/11/2023* | :white_check_mark: | :white_check_mark: | :white_check_mark: | :x: | +| [**DigitalRecruiters**](./src/hrflow_connectors/connectors/digitalrecruiters/README.md) | ATS | :white_check_mark: | *17/08/2023* | *23/11/2023* | :white_check_mark: | :white_check_mark: | :white_check_mark: | :x: | :x: | |**EngageATS** | ATS | 🎯 | | | | | | | | **EOLIA Software** | ATS | 🎯 | | | | | | | | **Eploy** | ATS | 🎯 | | | | | | | @@ -135,7 +135,7 @@ We invite developers to join us in our mission to bring AI and data integration | **Indeed** | Job Board | 🎯 | | | | **Inzojob** | Job Board | 🎯 | | | | **Jobijoba** | Job Board | 🎯 | | | -| [**Jobology**](./src/hrflow_connectors/connectors/jobology/README.md) | Job Board | :white_check_mark: | *21/12/2022* | *19/02/2024* | :x: | :x: | :x: | :x: | +| [**Jobology**](./src/hrflow_connectors/connectors/jobology/README.md) | Job Board | :white_check_mark: | *21/12/2022* | *19/02/2024* | :x: | :x: | :x: | :x: | :white_check_mark: | | **Jobrapido** | Job Board | 🎯 | | | | **JobTeaser** | Job Board | 🎯 | | | | **Jobtransport** | Job Board | 🎯 | | | diff --git a/src/hrflow_connectors/connectors/jobology/connector.py b/src/hrflow_connectors/connectors/jobology/connector.py index 0f20c139a..48ac705aa 100644 --- a/src/hrflow_connectors/connectors/jobology/connector.py +++ b/src/hrflow_connectors/connectors/jobology/connector.py @@ -15,7 +15,11 @@ def rename_profile_fields(jobology_profile: t.Dict) -> t.Dict: return { - "job-key": jobology_profile["jobkey"], + "job-number": ( + jobology_profile["jobkey"][:10] + if len(jobology_profile.get("jobkey", "")) >= 10 + else None + ), "first_name": jobology_profile.get("firstName"), "last_name": jobology_profile.get("lastName"), "phone": jobology_profile.get("phone"), diff --git a/src/hrflow_connectors/connectors/jobology/docs/catch_profile.md b/src/hrflow_connectors/connectors/jobology/docs/catch_profile.md index 86a79e4ce..eb10f1b87 100644 --- a/src/hrflow_connectors/connectors/jobology/docs/catch_profile.md +++ b/src/hrflow_connectors/connectors/jobology/docs/catch_profile.md @@ -10,7 +10,7 @@ Imports candidates, in synchronization with jobology | Field | Type | Default | Description | | ----- | ---- | ------- | ----------- | | `logics` | `typing.List[typing.Callable[[typing.Dict], typing.Optional[typing.Dict]]]` | [] | List of logic functions | -| `format` | `typing.Callable[[typing.Dict], typing.Dict]` | [`format_jobology_profile`](../connector.py#L39) | Formatting function | +| `format` | `typing.Callable[[typing.Dict], typing.Dict]` | [`format_jobology_profile`](../connector.py#L43) | Formatting function | | `read_mode` | `str` | ReadMode.sync | If 'incremental' then `read_from` of the last run is given to Origin Warehouse during read. **The actual behavior depends on implementation of read**. In 'sync' mode `read_from` is neither fetched nor given to Origin Warehouse during read. | ## Source Parameters diff --git a/src/hrflow_connectors/connectors/meteojob/connector.py b/src/hrflow_connectors/connectors/meteojob/connector.py index dac117d3d..d55b4ad6c 100644 --- a/src/hrflow_connectors/connectors/meteojob/connector.py +++ b/src/hrflow_connectors/connectors/meteojob/connector.py @@ -15,7 +15,11 @@ def rename_profile_fields(meteojob_profile: t.Dict) -> t.Dict: return { - "job-key": meteojob_profile["jobkey"], + "job-number": ( + meteojob_profile["jobkey"][:10] + if len(meteojob_profile.get("jobkey", "")) >= 10 + else None + ), "first_name": meteojob_profile.get("firstName"), "last_name": meteojob_profile.get("lastName"), "phone": meteojob_profile.get("phone"), diff --git a/src/hrflow_connectors/connectors/meteojob/docs/catch_profile.md b/src/hrflow_connectors/connectors/meteojob/docs/catch_profile.md index 683026726..ebe0cb842 100644 --- a/src/hrflow_connectors/connectors/meteojob/docs/catch_profile.md +++ b/src/hrflow_connectors/connectors/meteojob/docs/catch_profile.md @@ -10,7 +10,7 @@ Imports candidates, in synchronization with Meteojob | Field | Type | Default | Description | | ----- | ---- | ------- | ----------- | | `logics` | `typing.List[typing.Callable[[typing.Dict], typing.Optional[typing.Dict]]]` | [] | List of logic functions | -| `format` | `typing.Callable[[typing.Dict], typing.Dict]` | [`format_meteojob_profile`](../connector.py#L39) | Formatting function | +| `format` | `typing.Callable[[typing.Dict], typing.Dict]` | [`format_meteojob_profile`](../connector.py#L43) | Formatting function | | `read_mode` | `str` | ReadMode.sync | If 'incremental' then `read_from` of the last run is given to Origin Warehouse during read. **The actual behavior depends on implementation of read**. In 'sync' mode `read_from` is neither fetched nor given to Origin Warehouse during read. | ## Source Parameters