Почему не удается присоединить к переходу коллбэки?

Question

[MariAnShum]

Доброго дня!

Продолжаю изучать statetransitions, библиотеку для создания ФСМ. Осуществлять переходы между состояниями и группировать их под единым именем мне уже удается, однако возникает проблема с подключением коллбэков: необходимо, чтобы при осуществлении перехода lexeme_and_meta_received срабатывала функция on_enter_wf_tag (выводит соответствующий отладочный принт и делает изменения в словаре объекта). Что было сделано:

• Явное указание функции в качестве kwarg'а в описании перехода: в качестве функции on (= осуществлять во время перехода) и after (= осуществить после перехода),
  
• Неявное присоединение функции к переходу с помощью ее названия: была сделана попытка начать название функции с after,
  
• Неявное присоединение функции к состоянию: состояние, в которое надо перейти, называется wf_tag, соответственно прикрепленный к нему коллбэк называется on_enter_wf_tag.
  

Ни один из перечисленных методов не дал результатов. Подскажите, пожалуйста, что еще стоит попробовать сделать?

Заранее спасибо! Код прилагаю.

from statemachine import StateMachine, State

class TestState(StateMachine):

    wf_lexeme_and_meta = State(initial=True)
    wf_tag = State()
    wf_meaning_and_exp = State()
    wf_sem_class = State()

    lexeme_and_meta_received = wf_lexeme_and_meta.to(wf_tag)
    tag_received = wf_tag.to(wf_meaning_and_exp)
    meaning_and_exp_received = wf_meaning_and_exp.to(wf_sem_class)
    sem_class_received = wf_sem_class.to(wf_lexeme_and_meta)

    proceed = lexeme_and_meta_received | tag_received | meaning_and_exp_received | sem_class_received

    def __init__(self):
        self.working_span = ""
        self.working_memory = {
            "lemma": "",
            "meta": "",
            "tag": "",
            "meaning": "",
            "exp": "",
            "sem class": ""
        }
        super().__init__()

    def before_proceed(self, span):
        self.working_span = span

    def on_enter_wf_tag(self):
        print("Получено значение:" + self.working_span)
        working_memory["lemma"] = self.working_span
        working_memory["meta"] = input("Введите мета-информацию о слове")


test_state = TestState()

print(test_state.current_state.name)

while True:
    span = input()
    test_state.proceed(span)
    print(test_state.working_span)
    print(test_state.working_memory)
    print(test_state.current_state.name)
    if span == "finish":
        break

Comments

[Максим Припадчев]

Ничего не понятно, callback - это функция которая передается в качестве параметра в другую функцию и там внутри другой функции выполняется, после того как определенное событие наступило. То есть когда мы говорим о callback, мы должны говорит о двух функциях или методах.

Неявное присоединение функции к переходу с помощью ее названия: была сделана попытка начать название функции с after,

Это вообще что такое?

[MariAnShum]

Максим Припадчев, приведу пример с заглавной страницы документации:

from statemachine import StateMachine, State

class TrafficLightMachine(StateMachine):
    "A traffic light machine"
    green = State(initial=True)
    yellow = State()
    red = State()

    cycle = (
        green.to(yellow)
        | yellow.to(red)
        | red.to(green)
    )

    def before_cycle(self, event: str, source: State, target: State, message: str = ""):
        message = ". " + message if message else ""
        return f"Running {event} from {source.id} to {target.id}{message}"

    def on_enter_red(self):
        print("Don't move.")

    def on_exit_red(self):
        print("Go ahead!")

Дальше там приводятся консольные команды. Суть в том, что перемещение между тремя состояниями выполняется с помощью вызова события cycle. Когда алгоритм входит в состояние red, в консоль выводится "Don't move", как описано в функции on_enter_red, хотя при переходе в red эта функция никогда явным образом не вызывается. Мне пришлось долго до этого доходить, и объяснение у меня только одно: каким-то образом библиотека умеет сегментировать название функции-callback'а и находить в нем ключевые слова, например on enter и on exit, а также before и after.

Исходя из Вашего определения, callback — это функция, которая выполняется при переходе из состояния в состояние, при том что сам переход тоже является функцией. И как раз к переходу мне не удается присоединить callback.

[Максим Припадчев]

Genta, Да поставила, ты меня в тупик конечно. Окей, я аналитик чистый python не моя специальность, но все таки такой некий удар по самолюбию я получил, уже час копаюсь в source коде библиотеки пока без успешно я до сих пор не могу понять как он понимает что нужно вызывать эти методы.

[MariAnShum]

Максим Припадчев, буду очень рада, если Вы найдете в source коде что-то интересное и поделитесь этим! На мой взгляд, библиотека действительно очень нестандартная.
Может быть, будет разумнее просто взять что-то более классическое ей на замену, например transitions...

[Максим Припадчев]

Genta, Про библиотеку я даже ничего не знаю, никогда не приходилось ей пользоваться, мне просто с позиции python'a интересно понять как это реализовано.

[Максим Припадчев]

Genta, А что вообще должен делать код? Потому что вот в принципе я на основе примера из библиотеки прохожу по всем состояниям.

class TestState(StateMachine):

    wf_lexeme_and_meta = State(initial=True)
    wf_tag = State()
    wf_meaning_and_exp = State()
    wf_sem_class = State()

    # lexeme_and_meta_received = wf_lexeme_and_meta.to(wf_tag)
    # tag_received = wf_tag.to(wf_meaning_and_exp)
    # meaning_and_exp_received = wf_meaning_and_exp.to(wf_sem_class)
    # sem_class_received = wf_sem_class.to(wf_lexeme_and_meta)

    proceed = (wf_lexeme_and_meta.to(wf_tag) | wf_tag.to(wf_meaning_and_exp) 
               | wf_meaning_and_exp.to(wf_sem_class) | wf_sem_class.to(wf_lexeme_and_meta))

    def __init__(self):
        self.working_span = ""
        self.working_memory = {
            "lemma": "",
            "meta": "",
            "tag": "",
            "meaning": "",
            "exp": "",
            "sem class": ""
        }
        super().__init__()

    def before_proceed(self, event: str, source: State, target: State, message: str = ""):
        print('I am working')
        message = ". " + message if message else ""
        return f"Running {event} from {source.id} to {target.id}{message}"
        

    def on_enter_wf_tag(self):
        print("Получено значение:" + self.working_span)
        self.working_memory["lemma"] = self.working_span
        self.working_memory["meta"] = input("Введите мета-информацию о слове")

    def on_exit_wf_tag(self):
        print("I am done!")

test_state = TestState()

print(test_state.current_state.name)

while True:
    span = input()
    test_state.proceed(span)
    print(test_state.working_span)
    print(test_state.working_memory)
    print(test_state.current_state.name)
    if span == "finish":
        break

[MariAnShum]

Максим Припадчев, изучу, спасибо!
Этот код должен быть загрузчиком данных в БД. Мне показалось удобным сделать это на основе FSM. Введено слово (один тип данных) — происходит переход, введено еще слово (уже другой тип данных) — опять переход. На таком общем подходе стоит callback, который обновляет поля объекта. При этом на каждом конкретном переходе, например между wf_lexeme_and_meta и wf_tag, стоит свой, отдельный callback, в котором полученные строки загружаются в конкретную таблицу БД.

[Vindicar]

Максим Припадчев, я бы предположил что метакласс или что-то подобное. При создании класса-потомка StateMachine ищет в его __dict__ все имена, которым присвоен объект State(), на их основании строит список состояний, а дальше ищет имена методов, базируясь на именах состояний.

[Максим Припадчев]

Vindicar, Это было мое первое предположение тоже, я открыл код метакласса https://github.com/fgmacedo/python-statemachine/bl... то ли мне навыков python не хватает, скажем прямо на практике мне создавать их не приходилось. Все ты прав, так и есть.

def _add_unbounded_callback(cls, attr_name, func):
        if func._is_event:
            # if func is an event, the `attr_name` will be replaced by an event trigger,
            # so we'll also give the ``func`` a new unique name to be used by the callback
            # machinery.
            cls.add_event(attr_name, func._transitions)
            attr_name = f"_{attr_name}_{uuid4().hex}"
            setattr(cls, attr_name, func)

Да, надо повышать квалификацию.