| Server IP : 167.235.224.122 / Your IP : 216.73.216.110 Web Server : Apache/2.4.58 (Ubuntu) System : Linux newplayground 6.8.0-136-generic #136-Ubuntu SMP PREEMPT_DYNAMIC Wed Jul 1 21:33:11 UTC 2026 aarch64 User : deploy ( 1000) PHP Version : 8.4.23 Disable Function : NONE MySQL : OFF | cURL : ON | WGET : ON | Perl : ON | Python : OFF | Sudo : ON | Pkexec : OFF Directory : /var/www/html/emajiwallet/node_modules/nx/src/tasks-runner/ |
Upload File : |
"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
exports.initTasksRunner = initTasksRunner;
exports.runDiscreteTasks = runDiscreteTasks;
exports.runContinuousTasks = runContinuousTasks;
const nx_json_1 = require("../config/nx-json");
const project_graph_1 = require("../project-graph/project-graph");
const run_command_1 = require("./run-command");
const invoke_runner_terminal_output_life_cycle_1 = require("./life-cycles/invoke-runner-terminal-output-life-cycle");
const perf_hooks_1 = require("perf_hooks");
const utils_1 = require("./utils");
const dotenv_1 = require("../utils/dotenv");
const life_cycle_1 = require("./life-cycle");
const task_orchestrator_1 = require("./task-orchestrator");
const create_task_hasher_1 = require("../hasher/create-task-hasher");
const client_1 = require("../daemon/client/client");
const task_results_life_cycle_1 = require("./life-cycles/task-results-life-cycle");
/**
* This function is deprecated. Do not use this
* @deprecated This function is deprecated. Do not use this
*/
async function initTasksRunner(nxArgs) {
perf_hooks_1.performance.mark('init-local');
(0, dotenv_1.loadRootEnvFiles)();
const nxJson = (0, nx_json_1.readNxJson)();
if (nxArgs.verbose) {
process.env.NX_VERBOSE_LOGGING = 'true';
}
const projectGraph = await (0, project_graph_1.createProjectGraphAsync)({ exitOnError: true });
return {
invoke: async (opts) => {
perf_hooks_1.performance.mark('code-loading:end');
// TODO: This polyfills the outputs if someone doesn't pass a task with outputs. Remove this in Nx 20
opts.tasks.forEach((t) => {
if (!t.outputs) {
t.outputs = (0, utils_1.getOutputs)(projectGraph.nodes, t.target, t.overrides);
}
});
const lifeCycle = new invoke_runner_terminal_output_life_cycle_1.InvokeRunnerTerminalOutputLifeCycle(opts.tasks);
const taskGraph = {
roots: opts.tasks.map((task) => task.id),
tasks: opts.tasks.reduce((acc, task) => {
acc[task.id] = task;
return acc;
}, {}),
dependencies: opts.tasks.reduce((acc, task) => {
acc[task.id] = [];
return acc;
}, {}),
continuousDependencies: opts.tasks.reduce((acc, task) => {
acc[task.id] = [];
return acc;
}, {}),
};
const taskResults = await (0, run_command_1.invokeTasksRunner)({
tasks: opts.tasks,
projectGraph,
taskGraph,
lifeCycle,
nxJson,
nxArgs: { ...nxArgs, parallel: opts.parallel },
loadDotEnvFiles: true,
initiatingProject: null,
initiatingTasks: [],
});
return {
status: Object.values(taskResults).some((taskResult) => taskResult.status === 'failure' || taskResult.status === 'skipped')
? 1
: 0,
taskGraph,
taskResults,
};
},
};
}
async function createOrchestrator(tasks, projectGraph, taskGraphForHashing, nxJson, lifeCycle) {
(0, dotenv_1.loadRootEnvFiles)();
const invokeRunnerTerminalLifecycle = new invoke_runner_terminal_output_life_cycle_1.InvokeRunnerTerminalOutputLifeCycle(tasks);
const taskResultsLifecycle = new task_results_life_cycle_1.TaskResultsLifeCycle();
const compositedLifeCycle = new life_cycle_1.CompositeLifeCycle([
...(0, run_command_1.constructLifeCycles)(invokeRunnerTerminalLifecycle),
taskResultsLifecycle,
lifeCycle,
]);
const { runnerOptions: options } = (0, run_command_1.getRunner)({}, nxJson);
let hasher = (0, create_task_hasher_1.createTaskHasher)(projectGraph, nxJson, options);
const taskGraph = {
roots: tasks.map((task) => task.id),
tasks: tasks.reduce((acc, task) => {
acc[task.id] = task;
return acc;
}, {}),
dependencies: tasks.reduce((acc, task) => {
acc[task.id] = [];
return acc;
}, {}),
continuousDependencies: tasks.reduce((acc, task) => {
acc[task.id] = [];
return acc;
}, {}),
};
const nxArgs = {
...options,
parallel: tasks.length,
lifeCycle: compositedLifeCycle,
};
(0, run_command_1.setEnvVarsBasedOnArgs)(nxArgs, true);
const orchestrator = new task_orchestrator_1.TaskOrchestrator(hasher, null, [], projectGraph, taskGraph, nxJson, nxArgs, false, client_1.daemonClient, undefined, taskGraphForHashing);
await orchestrator.init();
orchestrator.processAllScheduledTasks();
return orchestrator;
}
async function runDiscreteTasks(tasks, projectGraph, taskGraphForHashing, nxJson, lifeCycle) {
const orchestrator = await createOrchestrator(tasks, projectGraph, taskGraphForHashing, nxJson, lifeCycle);
let groupId = 0;
let nextBatch = orchestrator.nextBatch();
let batchResults = [];
/**
* Set of task ids that were part of batches
*/
const batchTasks = new Set();
while (nextBatch) {
for (const task in nextBatch.taskGraph.tasks) {
batchTasks.add(task);
}
batchResults.push(orchestrator.applyFromCacheOrRunBatch(true, nextBatch, groupId++));
nextBatch = orchestrator.nextBatch();
}
const taskResults = tasks
// Filter out tasks which were not part of batches
.filter((task) => !batchTasks.has(task.id))
.map((task) => orchestrator
.applyFromCacheOrRunTask(true, task, groupId++)
.then((r) => [r]));
return [...batchResults, ...taskResults];
}
async function runContinuousTasks(tasks, projectGraph, taskGraphForHashing, nxJson, lifeCycle) {
const orchestrator = await createOrchestrator(tasks, projectGraph, taskGraphForHashing, nxJson, lifeCycle);
return tasks.reduce((current, task, index) => {
current[task.id] = orchestrator.startContinuousTask(task, index);
return current;
}, {});
}