Hi , I'm using the SqlAlchemyConnector. How can I make the following query?
Copy code
async with await SqlAlchemyConnector.load(SQL_BLOCKER_NAME) as database:
merchants_ids = await database.fetch_all("SELECT id FROM merchants dm WHERE id NOT IN (:merchant_id)", parameters=excluded_merchants)
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.
