from mage_ai.services.stitch.stitch import StitchClientclient = StitchClient(config=dict(access_token='access_token'))sources = client.list_sources()source_id = sources[0]['id'] # Get source idclient.start_replication_job(source_id) # Start replication job
Sample output:
Copy
Start replication job for source 11111. Job name: 111111.222222.sync.abcd1234-a96e-4b48-a10c-9de147a72d64.Polling Stitch extraction status for source 11111. Current status: running.Polling Stitch extraction status for source 11111. Current status: running.Polling Stitch extraction status for source 11111. Current status: running.Extraction for source 11111 completed.Finish loading data for all streams: ['stream_1', 'stream_2'].