airbyte-lib: Refactor connectors (#34552)

airbyte-integrations/connectors/source-activecampaign/main.py

@@ -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()

airbyte-integrations/connectors/source-activecampaign/setup.py

@@ -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,
     },

airbyte-integrations/connectors/source-activecampaign/source_activecampaign/run.py

@@ -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:])

airbyte-integrations/connectors/source-adjust/main.py

@@ -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()

airbyte-integrations/connectors/source-adjust/setup.py

@@ -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,
     },

airbyte-integrations/connectors/source-adjust/source_adjust/run.py

@@ -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:])

airbyte-integrations/connectors/source-aha/main.py

@@ -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()

airbyte-integrations/connectors/source-aha/setup.py

@@ -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,
     },

airbyte-integrations/connectors/source-aha/source_aha/run.py

@@ -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:])

airbyte-integrations/connectors/source-aircall/main.py

@@ -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()

airbyte-integrations/connectors/source-aircall/setup.py

@@ -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,
     },

airbyte-integrations/connectors/source-aircall/source_aircall/run.py

@@ -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:])

airbyte-integrations/connectors/source-airtable/main.py

@@ -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()

airbyte-integrations/connectors/source-airtable/setup.py

@@ -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",

airbyte-integrations/connectors/source-airtable/source_airtable/run.py

@@ -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:])

airbyte-integrations/connectors/source-alpha-vantage/main.py

@@ -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()

airbyte-integrations/connectors/source-alpha-vantage/setup.py

@@ -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,
     },

airbyte-integrations/connectors/source-alpha-vantage/source_alpha_vantage/run.py

@@ -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:])

airbyte-integrations/connectors/source-amazon-ads/main.py

@@ -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()

airbyte-integrations/connectors/source-amazon-ads/setup.py

@@ -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",

airbyte-integrations/connectors/source-amazon-ads/source_amazon_ads/run.py

@@ -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:])