2 Commits

Author SHA1 Message Date
4cbde45293 fix: make output less chatty 2019-01-30 10:01:40 -07:00
559c7d64d6 feat: handle termination 2019-01-30 10:01:40 -07:00
3 changed files with 1 additions and 5 deletions

View File

@@ -34,7 +34,6 @@ function handleError(err) {
} }
async function fetchAndIndex() { async function fetchAndIndex() {
logger.debug('Fetching and indexing data...');
return mod(index, { elasticsearch: { ...esConfig, auth }, filter: { lat, lon, radius } }); return mod(index, { elasticsearch: { ...esConfig, auth }, filter: { lat, lon, radius } });
} }

View File

@@ -17,7 +17,6 @@ export default async function(indexName, opts = {}) {
const index = await createIndex(client, indexName); const index = await createIndex(client, indexName);
const records = await getAdbsExchangeData(opts.filter); const records = await getAdbsExchangeData(opts.filter);
logger.debug(`Record count:, ${records.length}`);
await bulkInsert(client, index, records); await bulkInsert(client, index, records);
logger.debug(`Successfully indexed ${records.length} records to ${index}`); logger.debug(`Successfully indexed ${records.length} records to ${index}`);

View File

@@ -58,10 +58,8 @@ export async function createIndex(client, index) {
}) })
.catch(err => { .catch(err => {
// check for existing index // check for existing index
if (err instanceof BadRequest) { if (err instanceof BadRequest)
logger.debug(`Index exists: ${realIndex}`);
return client.indices.get({ index: realIndex }).then(() => realIndex); return client.indices.get({ index: realIndex }).then(() => realIndex);
}
throw err; throw err;
}); });