Skip to content

Commit

Permalink
airbyte-lib: Refactor connectors (airbytehq#34552)
Browse files Browse the repository at this point in the history
  • Loading branch information
Joe Reuter authored and jatinyadav-cc committed Feb 26, 2024
1 parent c9b0e74 commit fa6b553
Show file tree
Hide file tree
Showing 755 changed files with 7,678 additions and 1,984 deletions.
9 changes: 2 additions & 7 deletions airbyte-integrations/connectors/source-activecampaign/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,7 @@
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_activecampaign import SourceActivecampaign
from source_activecampaign.run import run

if __name__ == "__main__":
source = SourceActivecampaign()
launch(source, sys.argv[1:])
run()
19 changes: 18 additions & 1 deletion airbyte-integrations/connectors/source-activecampaign/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,30 @@
]

setup(
entry_points={
"console_scripts": [
"source-activecampaign=source_activecampaign.run:run",
],
},
name="source_activecampaign",
description="Source implementation for Activecampaign.",
author="Airbyte",
author_email="contact@airbyte.io",
packages=find_packages(),
install_requires=MAIN_REQUIREMENTS,
package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
package_data={
"": [
# Include yaml files in the package (if any)
"*.yml",
"*.yaml",
# Include all json files in the package, up to 4 levels deep
"*.json",
"*/*.json",
"*/*/*.json",
"*/*/*/*.json",
"*/*/*/*/*.json",
]
},
extras_require={
"tests": TEST_REQUIREMENTS,
},
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_activecampaign import SourceActivecampaign


def run():
source = SourceActivecampaign()
launch(source, sys.argv[1:])
9 changes: 2 additions & 7 deletions airbyte-integrations/connectors/source-adjust/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,7 @@
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_adjust import SourceAdjust
from source_adjust.run import run

if __name__ == "__main__":
source = SourceAdjust()
launch(source, sys.argv[1:])
run()
19 changes: 18 additions & 1 deletion airbyte-integrations/connectors/source-adjust/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,30 @@
]

setup(
entry_points={
"console_scripts": [
"source-adjust=source_adjust.run:run",
],
},
name="source_adjust",
description="Source implementation for Adjust.",
author="Airbyte",
author_email="contact@airbyte.io",
packages=find_packages(),
install_requires=MAIN_REQUIREMENTS,
package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
package_data={
"": [
# Include yaml files in the package (if any)
"*.yml",
"*.yaml",
# Include all json files in the package, up to 4 levels deep
"*.json",
"*/*.json",
"*/*/*.json",
"*/*/*/*.json",
"*/*/*/*/*.json",
]
},
extras_require={
"tests": TEST_REQUIREMENTS,
},
Expand Down
14 changes: 14 additions & 0 deletions airbyte-integrations/connectors/source-adjust/source_adjust/run.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_adjust import SourceAdjust


def run():
source = SourceAdjust()
launch(source, sys.argv[1:])
9 changes: 2 additions & 7 deletions airbyte-integrations/connectors/source-aha/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,7 @@
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_aha import SourceAha
from source_aha.run import run

if __name__ == "__main__":
source = SourceAha()
launch(source, sys.argv[1:])
run()
19 changes: 18 additions & 1 deletion airbyte-integrations/connectors/source-aha/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,30 @@
]

setup(
entry_points={
"console_scripts": [
"source-aha=source_aha.run:run",
],
},
name="source_aha",
description="Source implementation for Aha.",
author="Airbyte",
author_email="contact@airbyte.io",
packages=find_packages(),
install_requires=MAIN_REQUIREMENTS,
package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
package_data={
"": [
# Include yaml files in the package (if any)
"*.yml",
"*.yaml",
# Include all json files in the package, up to 4 levels deep
"*.json",
"*/*.json",
"*/*/*.json",
"*/*/*/*.json",
"*/*/*/*/*.json",
]
},
extras_require={
"tests": TEST_REQUIREMENTS,
},
Expand Down
14 changes: 14 additions & 0 deletions airbyte-integrations/connectors/source-aha/source_aha/run.py
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_aha import SourceAha


def run():
source = SourceAha()
launch(source, sys.argv[1:])
9 changes: 2 additions & 7 deletions airbyte-integrations/connectors/source-aircall/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,7 @@
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_aircall import SourceAircall
from source_aircall.run import run

if __name__ == "__main__":
source = SourceAircall()
launch(source, sys.argv[1:])
run()
19 changes: 18 additions & 1 deletion airbyte-integrations/connectors/source-aircall/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,30 @@
]

setup(
entry_points={
"console_scripts": [
"source-aircall=source_aircall.run:run",
],
},
name="source_aircall",
description="Source implementation for Aircall.",
author="Airbyte",
author_email="contact@airbyte.io",
packages=find_packages(),
install_requires=MAIN_REQUIREMENTS,
package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
package_data={
"": [
# Include yaml files in the package (if any)
"*.yml",
"*.yaml",
# Include all json files in the package, up to 4 levels deep
"*.json",
"*/*.json",
"*/*/*.json",
"*/*/*/*.json",
"*/*/*/*/*.json",
]
},
extras_require={
"tests": TEST_REQUIREMENTS,
},
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_aircall import SourceAircall


def run():
source = SourceAircall()
launch(source, sys.argv[1:])
9 changes: 2 additions & 7 deletions airbyte-integrations/connectors/source-airtable/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,7 @@
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_airtable import SourceAirtable
from source_airtable.run import run

if __name__ == "__main__":
source = SourceAirtable()
launch(source, sys.argv[1:])
run()
5 changes: 5 additions & 0 deletions airbyte-integrations/connectors/source-airtable/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,6 +16,11 @@
]

setup(
entry_points={
"console_scripts": [
"source-airtable=source_airtable.run:run",
],
},
name="source_airtable",
description="Source implementation for Airtable.",
author="Airbyte",
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_airtable import SourceAirtable


def run():
source = SourceAirtable()
launch(source, sys.argv[1:])
9 changes: 2 additions & 7 deletions airbyte-integrations/connectors/source-alpha-vantage/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,12 +2,7 @@
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_alpha_vantage import SourceAlphaVantage
from source_alpha_vantage.run import run

if __name__ == "__main__":
source = SourceAlphaVantage()
launch(source, sys.argv[1:])
run()
19 changes: 18 additions & 1 deletion airbyte-integrations/connectors/source-alpha-vantage/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -16,13 +16,30 @@
]

setup(
entry_points={
"console_scripts": [
"source-alpha-vantage=source_alpha_vantage.run:run",
],
},
name="source_alpha_vantage",
description="Source implementation for Alpha Vantage.",
author="Airbyte",
author_email="contact@airbyte.io",
packages=find_packages(),
install_requires=MAIN_REQUIREMENTS,
package_data={"": ["*.json", "*.yaml", "schemas/*.json", "schemas/shared/*.json"]},
package_data={
"": [
# Include yaml files in the package (if any)
"*.yml",
"*.yaml",
# Include all json files in the package, up to 4 levels deep
"*.json",
"*/*.json",
"*/*/*.json",
"*/*/*/*.json",
"*/*/*/*/*.json",
]
},
extras_require={
"tests": TEST_REQUIREMENTS,
},
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,14 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_alpha_vantage import SourceAlphaVantage


def run():
source = SourceAlphaVantage()
launch(source, sys.argv[1:])
11 changes: 2 additions & 9 deletions airbyte-integrations/connectors/source-amazon-ads/main.py
Original file line number Diff line number Diff line change
Expand Up @@ -2,14 +2,7 @@
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_amazon_ads import SourceAmazonAds
from source_amazon_ads.config_migrations import MigrateStartDate
from source_amazon_ads.run import run

if __name__ == "__main__":
source = SourceAmazonAds()
MigrateStartDate.migrate(sys.argv[1:], source)
launch(source, sys.argv[1:])
run()
5 changes: 5 additions & 0 deletions airbyte-integrations/connectors/source-amazon-ads/setup.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,11 @@
]

setup(
entry_points={
"console_scripts": [
"source-amazon-ads=source_amazon_ads.run:run",
],
},
name="source_amazon_ads",
description="Source implementation for Amazon Ads.",
author="Airbyte",
Expand Down
Original file line number Diff line number Diff line change
@@ -0,0 +1,16 @@
#
# Copyright (c) 2023 Airbyte, Inc., all rights reserved.
#


import sys

from airbyte_cdk.entrypoint import launch
from source_amazon_ads import SourceAmazonAds
from source_amazon_ads.config_migrations import MigrateStartDate


def run():
source = SourceAmazonAds()
MigrateStartDate.migrate(sys.argv[1:], source)
launch(source, sys.argv[1:])
Loading

0 comments on commit fa6b553

Please sign in to comment.