def check_result(self, query, expected, test_logical=False,
                     skip_json=False, output="OUTPUT",
                     algebra=MyriaLeftDeepTreeAlgebra):
        actual = self.execute_query(query, test_logical=test_logical,
                                    skip_json=skip_json, output=output,
                                    algebra=algebra)
        self.assertEquals(actual, expected)
Allow timer based processing
dataset/ETHPy150Open uwescience/raco/raco/datalog/datalog_test.py/DatalogTestCase.check_result--crossover with--dataset/ETHPy150Open ioflo/ioflo/ioflo/aio/proto/stacking.py/Stack.serviceTimers