SendEvent::process

public function process(Item $item): Result
{
	$result = new Result();

	$factory = Container::getInstance()->getFactory($item->getEntityTypeId());
	if (!$factory || !$factory->isStagesSupported())
	{
		return $result;
	}

	$stage = $factory->getStage((string)$item->getStageId());
	if (!$stage)
	{
		return $result;
	}

	if (Ml\Scoring::isMlAvailable() && !PhaseSemantics::isFinal($stage->getSemantics()))
	{
		Ml\Scoring::queuePredictionUpdate(
			$item->getEntityTypeId(),
			$item->getId(),
			[
				'EVENT_TYPE' => Ml\Scoring::EVENT_ENTITY_UPDATE,
			],
		);
	}

	return $result;
}