Add raw schema prefix to query in pull_missing_events

2018-11-14 14:39:34 -08:00
parent a948305e7a
commit 10e93bb01f
1 changed files with 1 additions and 1 deletions
--- 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;