Source Wrike: Changed last records to last record (#37600)

Signed-off-by: Artem Inzhyyants <[email protected]>
Co-authored-by: Artem Inzhyyants <[email protected]>
Co-authored-by: Artem Inzhyyants <[email protected]>

Author: lazebnyi

airbyte-integrations/connectors/source-wrike/Dockerfile

@@ -18,15 +18,13 @@ acceptance_tests:
     tests:
       - config_path: "secrets/config.json"
         configured_catalog_path: "integration_tests/configured_catalog.json"
+        expect_records:
+          path: "integration_tests/expected_records.jsonl"
         empty_streams:
           - name: comments
             bypass_reason: "Sandbox accounts dont have permission for accessing the stream"
-          - name: workflows
-            bypass_reason: "Sandbox accounts can't seed the stream"
-  # TODO uncomment this block to specify that the tests should assert the connector outputs the records provided in the input file a file
-  #        expect_records:
-  #          path: "integration_tests/expected_records.jsonl"
-  #          exact_order: no
+          - name: customfields
+            bypass_reason: "Sandbox accounts dont have permission for accessing the stream"
   incremental:
     bypass_reason: "This connector does not implement incremental sync"
   # TODO uncomment this block this block if your connector implements incremental sync:

airbyte-integrations/connectors/source-wrike/acceptance-test-config.yml

@@ -0,0 +1,4 @@
+{"stream":"tasks","data":{"id":"IEAFPQHKKQ42CBKR","accountId":"IEAFPQHK","title":"Getting Started With Wrike","status":"Active","importance":"Normal","createdDate":"2022-09-20T07:55:57Z","updatedDate":"2022-09-20T07:55:57Z","dates":{"type":"Backlog"},"scope":"WsTask","customStatusId":"IEAFPQHKJMAAAAAA","permalink":"https://www.wrike.com/open.htm?id=966853969","priority":"1e95a8008000000000008800"},"emitted_at":1714638763113}
+{"stream":"folders","data":{"id":"IEAFPQHKI7777777","title":"Root","childIds":["IEAFPQHKI442CLBD","IEAFPQHKI442CAJ2"],"scope":"WsRoot"},"emitted_at":1714638763678}
+{"stream":"contacts","data":{"id":"KX7ZDWOP","firstName":"My Team","lastName":"","type":"Group","profiles":[{"accountId":"IEAFPQHK","role":"User","external":false,"admin":false,"owner":false}],"avatarUrl":"https://www.wrike.com/avatars/default/internal_users_group.png","timezone":"Z","locale":"en","deleted":false,"memberIds":["KUAOFOSO"],"myTeam":true},"emitted_at":1714638763950}
+{"stream":"workflows","data":{"id":"IEAFPQHKK772QPYW","name":"Default Workflow","standard":true,"hidden":false,"customStatuses":[{"id":"IEAFPQHKJMAAAAAA","name":"New","standardName":true,"color":"Blue","standard":true,"group":"Active","hidden":false},{"id":"IEAFPQHKJMC4DE2Q","name":"In Progress","standardName":true,"color":"Turquoise","standard":false,"group":"Active","hidden":false},{"id":"IEAFPQHKJMAAAAAB","name":"Completed","standardName":true,"color":"Green","standard":true,"group":"Completed","hidden":false},{"id":"IEAFPQHKJMAAAAAC","name":"On Hold","standardName":true,"color":"Gray","standard":true,"group":"Deferred","hidden":false},{"id":"IEAFPQHKJMAAAAAD","name":"Cancelled","standardName":true,"color":"Gray","standard":true,"group":"Cancelled","hidden":false}]},"emitted_at":1714638764471}

airbyte-integrations/connectors/source-wrike/integration_tests/expected_records.jsonl

@@ -4,6 +4,8 @@ data:
       - app-us*.wrike.com
       - app-eu*.wrike.com
       - www.wrike.com
+  connectorBuildOptions:
+    baseImage: docker.io/airbyte/python-connector-base:1.2.0@sha256:c22a9d97464b69d6ef01898edf3f8612dc11614f05a84984451dde195f337db9
   remoteRegistries:
     pypi:
       enabled: true
@@ -16,7 +18,7 @@ data:
   connectorSubtype: api
   connectorType: source
   definitionId: 9c13f986-a13b-4988-b808-4705badf71c2
-  dockerImageTag: 0.2.0
+  dockerImageTag: 0.2.1
   dockerRepository: airbyte/source-wrike
   githubIssueLabel: source-wrike
   icon: wrike.svg

airbyte-integrations/connectors/source-wrike/metadata.yaml

@@ -0,0 +1,29 @@
+[build-system]
+requires = [ "poetry-core>=1.0.0",]
+build-backend = "poetry.core.masonry.api"
+
+[tool.poetry]
+version = "0.2.1"
+name = "source-wrike"
+description = "Source implementation for Wrike."
+authors = [ "Airbyte <[email protected]>",]
+license = "MIT"
+readme = "README.md"
+documentation = "https://docs.airbyte.com/integrations/sources/wrike"
+homepage = "https://airbyte.com"
+repository = "https://github.com/airbytehq/airbyte"
+[[tool.poetry.packages]]
+include = "source_wrike"
+
+[tool.poetry.dependencies]
+python = "^3.9,<3.12"
+airbyte-cdk = "^0"
+
+[tool.poetry.scripts]
+source-wrike = "source_wrike.run:run"
+
+[tool.poetry.group.dev.dependencies]
+requests-mock = "^1.9.3"
+pytest-mock = "^3.6"
+pytest = "^6.1"
+

airbyte-integrations/connectors/source-wrike/poetry.lock

@@ -1,4 +1,4 @@
-version: "0.29.0"
+version: "0.85.0"
 
 definitions:
   selector:
@@ -19,7 +19,7 @@ definitions:
     type: "DefaultPaginator"
     pagination_strategy:
       type: "CursorPagination"
-      cursor_value: "{{ last_records['nextPageToken'] }}"
+      cursor_value: "{{ last_record['nextPageToken'] }}"
     page_token_option:
       type: "RequestPath"
       field_name: "nextPageToken"

airbyte-integrations/connectors/source-wrike/pyproject.toml

@@ -10,10 +10,10 @@
       "type": ["string", "null"]
     },
     "standard": {
-      "type": ["string", "null"]
+      "type": ["boolean", "null"]
     },
     "hidden": {
-      "type": ["string", "null"]
+      "type": ["boolean", "null"]
     },
     "customStatuses": {
       "type": ["array", "null"],
@@ -33,13 +33,13 @@
             "type": ["string", "null"]
           },
           "standard": {
-            "type": ["string", "null"]
+            "type": ["boolean", "null"]
           },
           "group": {
             "type": ["string", "null"]
           },
           "hidden": {
-            "type": ["string", "null"]
+            "type": ["boolean", "null"]
           }
         }
       }

airbyte-integrations/connectors/source-wrike/requirements.txt

@@ -33,6 +33,7 @@ The Wrike source connector supports the following streams:
 * [Comments](https://developers.wrike.com/api/v4/comments/)\(Full Refresh\)
 * [Contacts](https://developers.wrike.com/api/v4/contacts/)\(Full Refresh\)
 * [Folders](https://developers.wrike.com/api/v4/folders-projects/)\(Full Refresh\)
+* [Workflows](https://developers.wrike.com/api/v4/workflows/)\(Full Refresh\)
 
 ### Data type mapping
 
@@ -44,8 +45,9 @@ The Wrike connector should not run into Wrike API limitations under normal usage
 
 ## Changelog
 
-| Version | Date       | Pull Request                                             | Subject                                                                                                                                                |
-|:--------|:-----------|:---------------------------------------------------------|:-------------------------------------------------------------------------------------------------------------------------------------------------------|
-| 0.2.0   | 2023-10-10 | [31058](https://github.com/airbytehq/airbyte/pull/31058) | Migrate to low code.
-| 0.1.0   | 2022-08-16 | [15638](https://github.com/airbytehq/airbyte/pull/15638) | Initial version/release of the connector.
+| Version | Date       | Pull Request                                             | Subject                                                                |
+|:--------|:-----------|:---------------------------------------------------------|:-----------------------------------------------------------------------|
+| 0.2.1   | 2024-04-30 | [31058](https://github.com/airbytehq/airbyte/pull/31058) | Changed last_records to last_record. Fix schema for stream `workflows` |
+| 0.2.0   | 2023-10-10 | [31058](https://github.com/airbytehq/airbyte/pull/31058) | Migrate to low code.                                                   |
+| 0.1.0   | 2022-08-16 | [15638](https://github.com/airbytehq/airbyte/pull/15638) | Initial version/release of the connector.                              |