Skip to content

Latest commit

 

History

History
executable file
·
116 lines (82 loc) · 1.87 KB

README.md

File metadata and controls

executable file
·
116 lines (82 loc) · 1.87 KB

jobs

Available Operations

cancel_job

Cancel a running Job

Example Usage

import airbyte
from airbyte.models import operations

s = airbyte.Airbyte(
    security=shared.Security(
        bearer_auth="YOUR_BEARER_TOKEN_HERE",
    ),
)

req = operations.CancelJobRequest(
    job_id=512393,
)

res = s.jobs.cancel_job(req)

if res.job_response is not None:
    # handle response

create_job

Trigger a sync or reset job of a connection

Example Usage

import airbyte
from airbyte.models import shared

s = airbyte.Airbyte(
    security=shared.Security(
        bearer_auth="YOUR_BEARER_TOKEN_HERE",
    ),
)

req = shared.JobCreateRequest(
    connection_id='odio',
    job_type=shared.JobTypeEnum.RESET,
)

res = s.jobs.create_job(req)

if res.job_response is not None:
    # handle response

get_job

Get Job status and details

Example Usage

import airbyte
from airbyte.models import operations

s = airbyte.Airbyte(
    security=shared.Security(
        bearer_auth="YOUR_BEARER_TOKEN_HERE",
    ),
)

req = operations.GetJobRequest(
    job_id=977496,
)

res = s.jobs.get_job(req)

if res.job_response is not None:
    # handle response

list_jobs

List Jobs by sync type

Example Usage

import airbyte
from airbyte.models import operations, shared

s = airbyte.Airbyte(
    security=shared.Security(
        bearer_auth="YOUR_BEARER_TOKEN_HERE",
    ),
)

req = operations.ListJobsRequest(
    connection_id='quisquam',
    job_type=shared.JobTypeEnum.RESET,
    limit=606476,
    offset=338159,
)

res = s.jobs.list_jobs(req)

if res.jobs_response is not None:
    # handle response