D-Net

import eu.dnetlib.msro.workflows.GraphNode;

import eu.dnetlib.msro.workflows.ProcessStatus;

import eu.dnetlib.msro.workflows.WorkflowsConstants;

import eu.dnetlib.msro.workflows.util.NodeHelper;

import eu.dnetlib.msro.workflows.util.NodeTokenCallback;

import eu.dnetlib.services.async.AsyncMethodStatus;

		try {

			for (final GraphNode node : process.getGraph().startNodes()) {

				final Token token = new Token(node.getName(), newNodeTokenCallback(process, node));

				token.getEnv().addAttributes(process.getEnv().getAttributes());

					if (list.size() == process.getGraph().getNumberOfIncomingArcs(node)) {

						final Token token = new Token(node.getName(), newNodeTokenCallback(process, node));

						token.getEnv().addAttributes(mergeEnvParams(list.toArray(new Token[list.size()])));

						process.getTokens().add(token);

						process.setLastActivityDate(DateUtils.now());

				} else {

					final Token token = new Token(node.getName(), newNodeTokenCallback(process, node));

					token.getEnv().addAttributes(oldToken.getEnv().getAttributes());

					process.getTokens().add(token);

					process.setLastActivityDate(DateUtils.now());