diff options
| author | Alex Browne <stephenalexbrowne@gmail.com> | 2018-11-15 06:39:34 +0800 |
|---|---|---|
| committer | Alex Browne <stephenalexbrowne@gmail.com> | 2018-12-05 06:24:48 +0800 |
| commit | 10e93bb01ffcf029821430781ef582a24901a461 (patch) | |
| tree | 77b43b2bfb9c3caf792eb9c4e8c6bb2f46093ae4 /packages | |
| parent | a948305e7a488ad01404fa04c95dacc98b4b0061 (diff) | |
| download | dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar.gz dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.tar.zst dexon-sol-tools-10e93bb01ffcf029821430781ef582a24901a461.zip | |
Add raw schema prefix to query in pull_missing_events
Diffstat (limited to 'packages')
| -rw-r--r-- | packages/pipeline/src/scripts/pull_missing_events.ts | 2 |
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; |