Writing tests for our pipeline is an important step towards an efficient and effective data-processing software development. Unit test in beam usually being done using DirectRunner which included in both of Java and Python SDK.