AbstractBossFlowModule / CtrlExMemFlow.py

Update CtrlExMemFlow.py

7bd6b7e almost 3 years ago

502 Bytes

from typing import Dict, Any

from aiflows.base_flows import CircularFlow
from aiflows.utils import logging
from abc import ABC, abstractmethod


logging.set_verbosity_debug()
log = logging.get_logger(__name__)


class CtrlExMemFlow(CircularFlow, ABC):
    @abstractmethod
    def _on_reach_max_round(self):
        pass

    @abstractmethod
    @CircularFlow.output_msg_payload_processor
    def detect_finish_or_continue(self, output_payload: Dict[str, Any], src_flow) -> Dict[str, Any]:
        pass

	from typing import Dict, Any

	from aiflows.base_flows import CircularFlow
	from aiflows.utils import logging
	from abc import ABC, abstractmethod


	logging.set_verbosity_debug()
	log = logging.get_logger(__name__)


	class CtrlExMemFlow(CircularFlow, ABC):
	@abstractmethod
	def _on_reach_max_round(self):
	pass

	@abstractmethod
	@CircularFlow.output_msg_payload_processor
	def detect_finish_or_continue(self, output_payload: Dict[str, Any], src_flow) -> Dict[str, Any]:
	pass