mcp_sync_connection.py

@mcp.tool()
def sync_connection(id: str) -> str:
    """
    Tool for syncing a fivetran connection by ID.

    Parameters:
        id (str): id of the connection
    """
    url = f"https://api.fivetran.com/v1/connectors/{id}"
    data = {
        'paused': False
    }

    requests.request("PATCH", url, json=data, headers=headers)

    url = f"https://api.fivetran.com/v1/connections/{id}/sync"
    payload = {"force": True}
    response = requests.request("POST", url, json=payload, headers=headers)

    return response.json()