add AirbyteConnection, AirbyteSync and run_connection_sync

[zzstoatzz]

Adds a AirbyteConnection(JobBlock) and AirbyteSync(JobRun) enabling the new flow run_connection_sync.

Adds a new client method get_job_info to allow inclusion of records_synced in the AirbyteSyncResult.

Closes #22

Example

from prefect import flow
from prefect_airbyte.server import AirbyteServer
from prefect_airbyte.connections import AirbyteConnection
from prefect_airbyte.flows import run_connection_sync

server = AirbyteServer()

connection = AirbyteConnection(
    airbyte_server=server,
    connection_id="7e78757d-fd7f-421b-80a5-f329dbdadf1b",
    status_updates=True,
)

@flow
def airbyte_syncs():
    # do some setup

    sync_result = run_connection_sync(
        airbyte_connection=connection,
    )

    # do some other things, like trigger DBT based on number of records synced
    print(f'{sync_result.records_synced}')

Screenshots

Checklist

• References any related issue by including "Closes #" or "Closes ".
  • If no issue exists and your change is not a small fix, please create an issue first.
• Includes tests or only affects documentation.
• Passes pre-commit checks.
  • Run pre-commit install && pre-commit run --all locally for formatting and linting.
• Includes screenshots of documentation updates.
  • Run mkdocs serve view documentation locally.
• Summarizes PR's changes in CHANGELOG.md

[ahuang11]

This looks good; just minor comments!

[ahuang11]

A few more things I noticed.