Module neuralops.tests.test_runners

Unit tests for neuralops.runners module.

Functions

def test_autonomous_pipeline_imports()

Expand source code

def test_autonomous_pipeline_imports():
    """Verify autonomous pipeline can be imported."""
    import neuralops.runners.run_autonomous_48h_pipeline as auto_pipe
    assert auto_pipe is not None

Verify autonomous pipeline can be imported.

def test_build_all_streams()

Expand source code

def test_build_all_streams():
    """Verify pipeline module sweeps can be inspected."""
    import neuralops.runners.run_autonomous_48h_pipeline as auto_pipe
    assert hasattr(auto_pipe, "SWEEP_CONFIGS") or hasattr(auto_pipe, "main")

Verify pipeline module sweeps can be inspected.

def test_launch_parallel_sweep_import()

Expand source code

def test_launch_parallel_sweep_import():
    """Verify benchmarks launch_parallel_sweep module imports."""
    import neuralops.benchmarks.launch_parallel_sweep as lps
    assert lps is not None

Verify benchmarks launch_parallel_sweep module imports.

def test_main_entrypoints()

Expand source code

def test_main_entrypoints():
    """Verify runners package exposes its expected runner scripts."""
    import neuralops.runners as runners
    assert runners is not None

Verify runners package exposes its expected runner scripts.

def test_monitor_server_imports()

Expand source code

def test_monitor_server_imports():
    """Verify monitor server components can be imported cleanly."""
    import neuralops.runners.run_monitor_server as server
    assert hasattr(server, "main") or hasattr(server, "start_server") or server is not None

Verify monitor server components can be imported cleanly.

def test_monitor_stats_collection()

Expand source code

def test_monitor_stats_collection():
    """Verify monitor subpackage imports."""
    from neuralops.runners.monitor import (
        telemetry,
        stats,
    )
    assert telemetry is not None
    assert stats is not None

Verify monitor subpackage imports.

def test_run_continuous_orchestrator_imports()

Expand source code

def test_run_continuous_orchestrator_imports():
    """Verify continuous orchestrator imports cleanly."""
    import neuralops.runners.run_continuous_orchestrator as cont_orch
    assert cont_orch is not None

Verify continuous orchestrator imports cleanly.

def test_unified_orchestrator_imports()

Expand source code

def test_unified_orchestrator_imports():
    """Verify unified orchestrator can be imported cleanly."""
    import neuralops.runners.unified_orchestrator as orchestrator
    assert orchestrator is not None

Verify unified orchestrator can be imported cleanly.