Stitch in Mage

from mage_ai.services.stitch.stitch import StitchClient


client = StitchClient(config=dict(access_token='access_token'))

sources = client.list_sources()
source_id = sources[0]['id'] # Get source id

client.start_replication_job(source_id) # Start replication job

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'].