airbyte.cloud.constants

Useful constants for working with Airbyte Cloud features in PyAirbyte.

 1# Copyright (c) 2024 Airbyte, Inc., all rights reserved.
 2"""Useful constants for working with Airbyte Cloud features in PyAirbyte."""
 3
 4from __future__ import annotations
 5
 6from airbyte._util.api_imports import JobStatusEnum
 7
 8
 9FINAL_STATUSES: set[JobStatusEnum] = {
10    JobStatusEnum.SUCCEEDED,
11    JobStatusEnum.FAILED,
12    JobStatusEnum.CANCELLED,
13}
14"""The set of `.JobStatusEnum` strings that indicate a sync job has completed."""
15
16FAILED_STATUSES: set[JobStatusEnum] = {
17    JobStatusEnum.FAILED,
18    JobStatusEnum.CANCELLED,
19}
20"""The set of `.JobStatusEnum` strings that indicate a sync job has failed."""
21
22READABLE_DESTINATION_TYPES: set[str] = {
23    "bigquery",
24    "snowflake",
25}
26"""List of Airbyte Cloud destinations that PyAirbyte is able to read from."""
FINAL_STATUSES: set[airbyte_api.models.jobstatusenum.JobStatusEnum] = {<JobStatusEnum.SUCCEEDED: 'succeeded'>, <JobStatusEnum.CANCELLED: 'cancelled'>, <JobStatusEnum.FAILED: 'failed'>}

The set of airbyte.cloud.JobStatusEnum strings that indicate a sync job has completed.

FAILED_STATUSES: set[airbyte_api.models.jobstatusenum.JobStatusEnum] = {<JobStatusEnum.FAILED: 'failed'>, <JobStatusEnum.CANCELLED: 'cancelled'>}

The set of airbyte.cloud.JobStatusEnum strings that indicate a sync job has failed.

READABLE_DESTINATION_TYPES: set[str] = {'bigquery', 'snowflake'}

List of Airbyte Cloud destinations that PyAirbyte is able to read from.