Add a check in the task runner to wait until tasks running in any dep…

…ended upon packages are complete

 🐿 v2.10.0

src/cli-task.js

@@ -39,7 +39,7 @@ module.exports = (task) => {
 			logger.info(`Running ${tasks.length} tasks`);
 
 			// 6. execute all tasks
-			await runParallel(tasks, globals.concurrency);
+			await runParallel(sortedPackages, tasks, globals.concurrency);
 
 			timer.stop();
 

src/run-parallel.js

@@ -1,14 +1,46 @@
+const Semaphore = require('async-sema');
 const logger = require('./logger');
-const Sema = require('async-sema');
+const waitUntil = require('./wait-until');
 
-module.exports = (tasks = [], concurrency = 1) => {
-	const sema = new Sema(concurrency);
+const noRunningDependencies = (running, dependencies) => {
+	return !dependencies.some((dependency) => running.has(dependency));
+};
+
+module.exports = (packages = [], tasks = [], concurrency = 1) => {
+	const semaphore = new Semaphore(concurrency);
 
 	logger.info(`Executing up to ${concurrency} tasks at a time`);
 
+	const packagesRunning = new Set();
+
 	return Promise.all(
-		tasks.map((task) => {
-			return sema.acquire().then(task).then(() => sema.release());
+		tasks.map((task, i) => {
+			// TODO: number of tasks ~= number of packages
+			const packageName = packages[i].name;
+			const packageManifest = packages[i].manifest;
+
+			const allDependencies = Object.keys({
+				...packageManifest.dependencies,
+				...packageManifest.devDependencies,
+				...packageManifest.peerDependencies,
+				...packageManifest.optionalDependencies
+			});
+
+			return semaphore
+				.acquire()
+				.then(() => {
+					return waitUntil(() => {
+						return noRunningDependencies(packagesRunning, allDependencies);
+					});
+				})
+				.then(() => {
+					packagesRunning.add(packageName);
+					return task();
+				})
+				.then(() => {
+					packagesRunning.delete(packageName);
+					return semaphore.release();
+				});
 		})
 	);
 };

src/wait-until.js

@@ -0,0 +1,15 @@
+const wait = (ms = 100) => new Promise((resolve) => setTimeout(resolve, ms));
+
+module.exports = (check) => {
+	return new Promise((resolve) => {
+		const test = () => {
+			if (check()) {
+				resolve();
+			} else {
+				wait().then(test);
+			}
+		};
+
+		test();
+	});
+};