From 10e93bb01ffcf029821430781ef582a24901a461 Mon Sep 17 00:00:00 2001
From: Alex Browne <stephenalexbrowne@gmail.com>
Date: Wed, 14 Nov 2018 14:39:34 -0800
Subject: Add raw schema prefix to query in pull_missing_events

---
 packages/pipeline/src/scripts/pull_missing_events.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'packages')

diff --git a/packages/pipeline/src/scripts/pull_missing_events.ts b/packages/pipeline/src/scripts/pull_missing_events.ts
index bc0eac853..0af999a77 100644
--- a/packages/pipeline/src/scripts/pull_missing_events.ts
+++ b/packages/pipeline/src/scripts/pull_missing_events.ts
@@ -55,7 +55,7 @@ async function getStartBlockAsync(eventsRepository: Repository<ExchangeFillEvent
         return EXCHANGE_START_BLOCK;
     }
     const queryResult = await connection.query(
-        'SELECT block_number FROM exchange_fill_events ORDER BY block_number DESC LIMIT 1',
+        'SELECT block_number FROM raw.exchange_fill_events ORDER BY block_number DESC LIMIT 1',
     );
     const lastKnownBlock = queryResult[0].block_number;
     return lastKnownBlock - START_BLOCK_OFFSET;
-- 
cgit v1.2.3