Skip to content

mpi_tests

Models for all test Tasks.

Classes:

Name Description
TestMultiNodeCommunicationParameters

Model for test Task which verifies that the SocketCommunicator can write back to the Executor on a different node.

TestParameters

Model for most basic test case. Single core first-party Task. Uses only communication via pipes.

TestBinaryParameters

Parameters for a simple multi- threaded binary executable.

TestSocketParameters

Model for first-party test requiring communication via socket.

TestWriteOutputParameters

Model for test Task which writes an output file. Location of file is recorded in database.

TestReadOutputParameters

Model for test Task which locates an output file based on an entry in the database, if no path is provided.

TestMultiNodeCommunicationParameters

Bases: TaskParameters

Parameters for the test Task TestMultiNodeCommunication.

Test verifies communication across multiple machines.

Source code in lute/io/models/mpi_tests.py
38
39
40
41
42
43
44
45
46
47
48
49
class TestMultiNodeCommunicationParameters(TaskParameters):
    """Parameters for the test Task `TestMultiNodeCommunication`.

    Test verifies communication across multiple machines.
    """

    send_obj: Literal["plot", "array"] = Field(
        "array", description="Object to send to Executor. `plot` or `array`"
    )
    arr_size: Optional[int] = Field(
        None, description="Size of array to send back to Executor."
    )