aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorAlex Browne <stephenalexbrowne@gmail.com>2018-11-15 06:39:34 +0800
committerAlex Browne <stephenalexbrowne@gmail.com>2018-12-05 06:24:48 +0800
commit10e93bb01ffcf029821430781ef582a24901a461 (patch)
tree77b43b2bfb9c3caf792eb9c4e8c6bb2f46093ae4
parenta948305e7a488ad01404fa04c95dacc98b4b0061 (diff)
downloaddexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar
dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar.gz
dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar.bz2
dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar.lz
dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar.xz
dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar.zst
dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.zip
Add raw schema prefix to query in pull_missing_events
-rw-r--r--packages/pipeline/src/scripts/pull_missing_events.ts2
1 files changed, 1 insertions, 1 deletions
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;