Hello, Im trying to start 2 airbyte connections (s...
# help-api-cli-orchestration
v
Hello, Im trying to start 2 airbyte connections (sequential) with prefect.... this is my code but it doesnt work and i dont know why... someone to help me ? from prefect import Flow,task from prefect_airbyte.connections import AirbyteConnection from prefect_airbyte.flows import run_connection_sync from prefect_airbyte.server import AirbyteServer server = AirbyteServer.load("airbyte") connection = AirbyteConnection( airbyte_server=server, connection_id="XXXXXXXX", status_updates=True, ) connection2 = AirbyteConnection( airbyte_server=server, connection_id="YYYYYYYY", status_updates=True, ) @task def airbyte_syncs(): sync_result = run_connection_sync( airbyte_connection=connection ) @task def airbyte_syncs2(): sync_result = run_connection_sync( airbyte_connection=connection2 ) with Flow("test") as flow: a=airbyte_syncs() b=airbyte_syncs2() flow.run()
u
New message text here
v
@kapa.ai it doesnt work and I need to start 2 connections...
u
Based on the information provided, it seems like you're trying to set up two connections in Airbyte. Here's a general guide on how you can do this: 1. Log into your Airbyte account. If you're using Airbyte Cloud, you can log in [here](https://cloud.airbyte.com/workspaces). If you're using Airbyte Open Source, go to your local Airbyte page. 2. In the left navigation bar, click Sources. In the top-right corner, click + new source. 3. On the source setup page, select your desired source from the Source type dropdown and enter a name for this connector. 4. Authenticate your account if required. For example, if you're setting up a GitHub source, you would click
Authenticate your GitHub account
and log in and authorize to the GitHub account. 5. Set the Start date. This is the date from which you'd like to replicate data for streams. 6. Set up the source by clicking
Set up source
. 7. Repeat the steps for the second connection. Please note that a connection is individually created between a source and a destination. If you need to put the same data in two different destinations (for example, MySql and Kafka), you would need to create two separate connections. This is because some connections support incremental + dedup sync mode and others do not ([source](https://airbytehq.slack.com/archives/C021JANJ6TY/p1666883515844539)). If you're still having trouble, please reach out to the Airbyte team on [Slack](https://slack.airbyte.io/) or create an issue on their [Github](https://github.com/airbytehq/airbyte).
m
Can you share the error log or something?
v
Thank you for your help. my mistake was: calling a flow into a task...
now its ok