agent_pipeline.py

# Copyright (c) Facebook, Inc. and its affiliates.
# All rights reserved.
#
# This source code is licensed under the license found in the
# LICENSE file in the root directory of this source tree.

import random
from simuleval.utils import entrypoint
from simuleval.agents import TextToTextAgent
from simuleval.agents.actions import ReadAction, WriteAction
from simuleval.agents import AgentPipeline


class DummyWaitkTextAgent(TextToTextAgent):
    waitk = 0
    vocab = [chr(i) for i in range(ord("A"), ord("Z") + 1)]

    def policy(self):
        lagging = len(self.states.source) - len(self.states.target)

        if lagging >= self.waitk or self.states.source_finished:
            prediction = random.choice(self.vocab)

            return WriteAction(prediction, finished=(lagging <= 1))
        else:
            return ReadAction()


class DummyWait2TextAgent(DummyWaitkTextAgent):
    waitk = 2


class DummyWait4TextAgent(DummyWaitkTextAgent):
    waitk = 4


@entrypoint
class DummyPipeline(AgentPipeline):
    pipeline = [DummyWait2TextAgent, DummyWait4TextAgent]