Merge branch 'master' into ddavydov/#1299-source-stripe-fix-schema

airbyte-config/init/src/main/resources/seed/source_definitions.yaml

@@ -882,11 +882,14 @@
 - name: Jira
   sourceDefinitionId: 68e63de2-bb83-4c7e-93fa-a8a9051e3993
   dockerRepository: airbyte/source-jira
-  dockerImageTag: 0.3.3
+  dockerImageTag: 0.3.4
   documentationUrl: https://docs.airbyte.com/integrations/sources/jira
   icon: jira.svg
   sourceType: api
   releaseStage: beta
+  allowedHosts:
+    hosts:
+      - "${domain}"
 - name: K6 Cloud
   sourceDefinitionId: e300ece7-b073-43a3-852e-8aff36a57f13
   dockerRepository: airbyte/source-k6-cloud

airbyte-config/init/src/main/resources/seed/source_specs.yaml

@@ -6959,7 +6959,7 @@
     supportsNormalization: false
     supportsDBT: false
     supported_destination_sync_modes: []
-- dockerImage: "airbyte/source-jira:0.3.3"
+- dockerImage: "airbyte/source-jira:0.3.4"
   spec:
     documentationUrl: "https://docs.airbyte.com/integrations/sources/jira"
     connectionSpecification:

airbyte-integrations/connectors/source-jira/Dockerfile

@@ -12,5 +12,5 @@ RUN pip install .
 ENV AIRBYTE_ENTRYPOINT "python /airbyte/integration_code/main.py"
 ENTRYPOINT ["python", "/airbyte/integration_code/main.py"]
 
-LABEL io.airbyte.version=0.3.3
+LABEL io.airbyte.version=0.3.4
 LABEL io.airbyte.name=airbyte/source-jira

airbyte-integrations/connectors/source-jira/source_jira/streams.py

@@ -303,7 +303,7 @@ class Issues(IncrementalJiraStream):
 
     cursor_field = "updated"
     extract_field = "issues"
-    use_cache = True
+    use_cache = False  # disable caching due to OOM errors in kubernetes
 
     def __init__(self, expand_changelog: bool = False, render_fields: bool = False, **kwargs):
         super().__init__(**kwargs)

airbyte-integrations/connectors/source-jira/unit_tests/test_streams.py

@@ -647,7 +647,12 @@ def test_issues_stream(config, issues_response):
 
 
 @responses.activate
-def test_issue_comments_stream(config, issue_comments_response):
+def test_issue_comments_stream(config, issues_response, issue_comments_response):
+    responses.add(
+        responses.GET,
+        f"https://{config['domain']}/rest/api/3/search?maxResults=50&fields=%2Aall&jql=project+in+%28%271%27%2C+%272%27%29",
+        json=issues_response,
+    )
     responses.add(
         responses.GET,
         f"https://{config['domain']}/rest/api/3/issue/TESTKEY13-1/comment?maxResults=50",
@@ -660,7 +665,7 @@ def test_issue_comments_stream(config, issue_comments_response):
     records = [r for r in
                stream.read_records(sync_mode=SyncMode.full_refresh)]
     assert len(records) == 2
-    assert len(responses.calls) == 1
+    assert len(responses.calls) == 2
 
 
 @responses.activate
@@ -789,7 +794,12 @@ def test_labels_stream(config, labels_response):
 
 
 @responses.activate
-def test_issue_worklogs_stream(config, issue_worklogs_response):
+def test_issue_worklogs_stream(config, issues_response, issue_worklogs_response):
+    responses.add(
+        responses.GET,
+        f"https://{config['domain']}/rest/api/3/search?maxResults=50&fields=%2Aall&jql=project+in+%28%271%27%2C+%272%27%29",
+        json=issues_response,
+    )
     responses.add(
         responses.GET,
         f"https://{config['domain']}/rest/api/3/issue/TESTKEY13-1/worklog?maxResults=50",
@@ -801,11 +811,16 @@ def test_issue_worklogs_stream(config, issue_worklogs_response):
     stream = IssueWorklogs(**args)
     records = [r for r in stream.read_records(sync_mode=SyncMode.full_refresh)]
     assert len(records) == 1
-    assert len(responses.calls) == 1
+    assert len(responses.calls) == 2
 
 
 @responses.activate
-def test_issue_watchers_stream(config, issue_watchers_response):
+def test_issue_watchers_stream(config, issues_response, issue_watchers_response):
+    responses.add(
+        responses.GET,
+        f"https://{config['domain']}/rest/api/3/search?maxResults=50&fields=%2Aall&jql=project+in+%28%271%27%2C+%272%27%29",
+        json=issues_response,
+    )
     responses.add(
         responses.GET,
         f"https://{config['domain']}/rest/api/3/issue/TESTKEY13-1/watchers?maxResults=50",
@@ -817,11 +832,16 @@ def test_issue_watchers_stream(config, issue_watchers_response):
     stream = IssueWatchers(**args)
     records = [r for r in stream.read_records(sync_mode=SyncMode.full_refresh)]
     assert len(records) == 1
-    assert len(responses.calls) == 1
+    assert len(responses.calls) == 2
 
 
 @responses.activate
-def test_issue_votes_stream(config, issue_votes_response):
+def test_issue_votes_stream(config, issues_response, issue_votes_response):
+    responses.add(
+        responses.GET,
+        f"https://{config['domain']}/rest/api/3/search?maxResults=50&fields=%2Aall&jql=project+in+%28%271%27%2C+%272%27%29",
+        json=issues_response,
+    )
     responses.add(
         responses.GET,
         f"https://{config['domain']}/rest/api/3/issue/TESTKEY13-1/votes?maxResults=50",
@@ -834,11 +854,16 @@ def test_issue_votes_stream(config, issue_votes_response):
     records = [r for r in stream.read_records(sync_mode=SyncMode.full_refresh, stream_slice={"key": "Project1"})]
 
     assert len(records) == 1
-    assert len(responses.calls) == 1
+    assert len(responses.calls) == 2
 
 
 @responses.activate
-def test_issue_remote_links_stream(config, issue_remote_links_response):
+def test_issue_remote_links_stream(config, issues_response, issue_remote_links_response):
+    responses.add(
+        responses.GET,
+        f"https://{config['domain']}/rest/api/3/search?maxResults=50&fields=%2Aall&jql=project+in+%28%271%27%2C+%272%27%29",
+        json=issues_response,
+    )
     responses.add(
         responses.GET,
         f"https://{config['domain']}/rest/api/3/issue/TESTKEY13-1/remotelink?maxResults=50",
@@ -851,7 +876,7 @@ def test_issue_remote_links_stream(config, issue_remote_links_response):
     records = [r for r in stream.read_records(sync_mode=SyncMode.full_refresh, stream_slice={"key": "Project1"})]
 
     assert len(records) == 2
-    assert len(responses.calls) == 1
+    assert len(responses.calls) == 2
 
 
 @responses.activate

docs/integrations/sources/jira.md

@@ -122,10 +122,11 @@ Check out common troubleshooting issues for the Jira connector on our Discourse
 
 The Jira connector should not run into Jira API limitations under normal usage. Please [create an issue](https://github.com/airbytehq/airbyte/issues) if you see any rate limit issues that are not automatically retried successfully.
 
-## CHANGELOG
+## CHANGELOG 
 
 | Version | Date       | Pull Request                                                | Subject                                                                                                                 |
 |:--------|:-----------|:------------------------------------------------------------|:------------------------------------------------------------------------------------------------------------------------|
+| 0.3.4   | 2023-02-14 | [\#23006](https://github.com/airbytehq/airbyte/pull/23006)  | Remove caching for `Issues` stream                                                                                      |
 | 0.3.3   | 2023-01-04 | [\#20739](https://github.com/airbytehq/airbyte/pull/20739)  | fix: check_connection fails if no projects are defined                                                                  |
 | 0.3.2   | 2022-12-23 | [\#20859](https://github.com/airbytehq/airbyte/pull/20859)  | Fixed pagination for streams `issue_remote_links`, `sprints`                                                            |
 | 0.3.1   | 2022-12-14 | [\#20128](https://github.com/airbytehq/airbyte/pull/20128)  | Improved code to become beta                                                                                            |