Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

feat: add reasons to AirbyteStreamStatusTraceMessage #74

Merged
merged 7 commits into from
May 16, 2024
Merged

feat: add reasons to AirbyteStreamStatusTraceMessage #74

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
7 commits
Select commit Hold shift + click to select a range
777b9a4
feat: add RATE_LIMITED enum + metadata to AirbyteStreamStatusTraceMes…
subodh1810 May 3, 2024
ab3e302
use timestamp instead of metadata
subodh1810 May 3, 2024
684fcab
til instead of till
subodh1810 May 3, 2024
e2c7ad4
update protocol changes according to discussion
subodh1810 May 8, 2024
b192acd
Merge branch 'main' into add-rate-limited-enum-trace-message
subodh1810 May 8, 2024
c6523f6
use integer instead of number
subodh1810 May 13, 2024
c76a2f9
add TODOs
subodh1810 May 13, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
31 changes: 31 additions & 0 deletions protocol-models/src/main/resources/airbyte_protocol/airbyte_protocol.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -239,6 +239,7 @@ definitions:
- ANALYTICS
emitted_at:
description: "the time in ms that the message was emitted"
# TODO : This should have been an integer instead of a number, need to fix this
type: number
error:
description: "error trace message: the error object"
Expand Down Expand Up @@ -315,6 +316,30 @@ definitions:
- RUNNING # Stream has read its first byte/message
- COMPLETE # Stream has completed executing without interruption or error
- INCOMPLETE # Stream has stopped due to an interruption or error
AirbyteStreamStatusReasonType:
type: string
description: >
Type of reason
enum:
- RATE_LIMITED
AirbyteStreamStatusRateLimitedReason:
type: object
description: Rate Limited Information
properties:
quota_reset:
description: "Optional time in ms representing when the API quota is going to be reset"
type: integer
AirbyteStreamStatusReason:
type: object
required:
- type
description: >
The reason associated with the status of the stream.
properties:
type:
"$ref": "#/definitions/AirbyteStreamStatusReasonType"
rate_limited:
"$ref": "#/definitions/AirbyteStreamStatusRateLimitedReason"
AirbyteStreamStatusTraceMessage:
type: object
additionalProperties: true
Expand All @@ -328,6 +353,11 @@ definitions:
status:
description: "The current status of the stream"
"$ref": "#/definitions/AirbyteStreamStatus"
reasons:
description: "The reasons associated with the status of the stream"
type: array
items:
"$ref": "#/definitions/AirbyteStreamStatusReason"
AirbyteAnalyticsTraceMessage:
type: object
additionalProperties: true
Expand Down Expand Up @@ -367,6 +397,7 @@ definitions:
- CONNECTOR_CONFIG
emitted_at:
description: "the time in ms that the message was emitted"
# TODO : This should have been an integer instead of a number, need to fix this
type: number
connectorConfig:
description: "connector config orchestrator message: the updated config for the platform to store for this connector"
Expand Down
31 changes: 31 additions & 0 deletions protocol-models/src/main/resources/airbyte_protocol/v0/airbyte_protocol.yaml
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -239,6 +239,7 @@ definitions:
- STREAM_STATUS
- ANALYTICS
emitted_at:
# TODO : This should have been an integer instead of a number, need to fix this
description: "the time in ms that the message was emitted"
type: number
error:
Expand Down Expand Up @@ -316,6 +317,30 @@ definitions:
- RUNNING # Stream has read its first byte/message
- COMPLETE # Stream has completed executing without interruption or error
- INCOMPLETE # Stream has stopped due to an interruption or error
AirbyteStreamStatusReasonType:
type: string
description: >
Type of reason
enum:
- RATE_LIMITED
AirbyteStreamStatusRateLimitedReason:
type: object
description: Rate Limited Information
properties:
quota_reset:
description: "Optional time in ms representing when the API quota is going to be reset"
type: integer
AirbyteStreamStatusReason:
type: object
required:
- type
description: >
The reason associated with the status of the stream.
properties:
type:
"$ref": "#/definitions/AirbyteStreamStatusReasonType"
rate_limited:
"$ref": "#/definitions/AirbyteStreamStatusRateLimitedReason"
AirbyteStreamStatusTraceMessage:
type: object
additionalProperties: true
Expand All @@ -329,6 +354,11 @@ definitions:
status:
description: "The current status of the stream"
"$ref": "#/definitions/AirbyteStreamStatus"
reasons:
description: "The reasons associated with the status of the stream"
type: array
items:
"$ref": "#/definitions/AirbyteStreamStatusReason"
AirbyteAnalyticsTraceMessage:
type: object
additionalProperties: true
Expand Down Expand Up @@ -368,6 +398,7 @@ definitions:
- CONNECTOR_CONFIG
emitted_at:
description: "the time in ms that the message was emitted"
# TODO : This should have been an integer instead of a number, need to fix this
type: number
connectorConfig:
description: "connector config orchestrator message: the updated config for the platform to store for this connector"
Expand Down
Loading