@oasisdex/spock-etl - npm Package Compare versions

Comparing version 0.1.4 to 0.1.5

dist/processors/process.js

		@@ -106,14 +106,17 @@ "use strict";
		}
		const dependencies = getAllDependencies(processor);
		const query = dependencies.length === 0
		? `
		SELECT b.* FROM vulcan2x.block b
		WHERE b.id > ${job.last_block_id} ORDER BY id
		LIMIT ${batchSize};`
		: `
		SELECT b.* FROM vulcan2x.block b
		WHERE id<= (SELECT MIN(last_block_id) FROM vulcan2x.job WHERE name in(
		${dependencies.map((dependency) => `'${dependency}'`).join(',')}
		)) AND b.id > ${job.last_block_id} ORDER BY id
		LIMIT ${batchSize};`;
		const nextBlocks = (await c.manyOrNone(
		// prettier-ignore
		`
		SELECT b.*
		FROM vulcan2x.block b
		${getAllDependencies(processor)
		.map((d, i) => `JOIN vulcan2x.job j${i} ON j${i}.name='${d}' AND b.id <= j${i}.last_block_id`)
		.join('\n')}
		WHERE b.id > ${job.last_block_id}
		ORDER BY id
		LIMIT ${batchSize};
		`)) \|\| [];
		query)) \|\| [];
		return lodash_1.sortBy(nextBlocks, 'id');
		@@ -120,0 +123,0 @@ });

package.json

dist/processors/process.js.map

Sorry, the diff of this file is not supported yet

New alerts