import pytest

from octopus.tasks import pipe


def test_communicate():
    with pytest.raises(Exception):
        pipe.communicate(pipe=None)