Skip to content

Commit

Permalink
Fix description
Browse files Browse the repository at this point in the history
  • Loading branch information
tolik0 committed Jul 12, 2024
1 parent f532d3c commit b2fd84a
Show file tree
Hide file tree
Showing 5 changed files with 9 additions and 9 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -813,8 +813,8 @@ definitions:
type: boolean
default: False
global_parent_cursor:
title: Global Parent Cursor
description: Indicates whether the parent stream state as one cursor instead of partitions.
title: Whether to store cursor as one value instead of per partition
description: If parent stream have thousands of partitions, it can be more efficient to store cursor as one value instead of per partition. Lookback window should be used to avoid missing records that where added during the sync
type: boolean
default: false
lookback_window:
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1081,7 +1081,9 @@ class DatetimeBasedCursor(BaseModel):
title='Whether to skip requests if the start time equals the end time',
)
global_parent_cursor: Optional[bool] = Field(
False, description='Indicates whether the parent stream state as one cursor instead of partitions.', title='Global Parent Cursor'
False,
description='If parent stream have thousands of partitions, it can be more efficient to store cursor as one value instead of per partition. Lookback window should be used to avoid missing records that where added during the sync',
title='Whether to store cursor as one value instead of per partition',
)
lookback_window: Optional[str] = Field(
None,
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -1249,7 +1249,7 @@ definitions:
transformations:
- type: AddFields
fields:
- path: [ "issueId" ]
- path: ["issueId"]
value_type: string
value: "{{ stream_slice.issue_id }}"
state_migrations:
Expand Down Expand Up @@ -1277,7 +1277,7 @@ definitions:
transformations:
- type: AddFields
fields:
- path: [ "issueId" ]
- path: ["issueId"]
value_type: string
value: "{{ stream_slice.issue_id }}"
state_migrations:
Expand All @@ -1287,7 +1287,6 @@ definitions:
path: "issue/{{ stream_slice.issue_id }}/worklog"
extract_field: "worklogs"


streams:
# Full refresh streams

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -214,8 +214,8 @@ class Issues(IncrementalJiraStream):
def __init__(self, **kwargs):
super().__init__(**kwargs)
self._project_ids = []
self.issue_fields_stream = IssueFields(authenticator=self._session.auth, domain=self._domain, projects=self._projects)
self.projects_stream = Projects(authenticator=self._session.auth, domain=self._domain, projects=self._projects)
self.issue_fields_stream = IssueFields(authenticator=self._http_client._session.auth, domain=self._domain, projects=self._projects)
self.projects_stream = Projects(authenticator=self._http_client._session.auth, domain=self._domain, projects=self._projects)

def path(self, **kwargs) -> str:
return "search"
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -251,7 +251,6 @@ definitions:
datetime: "{{ now_utc().strftime('%Y-%m-%dT%H:%M:%SZ') }}"
datetime_format: "%Y-%m-%dT%H:%M:%SZ"


threads_stream:
$ref: "#/definitions/stream_base"
$parameters:
Expand Down

0 comments on commit b2fd84a

Please sign in to comment.