| 6790 | |
| 6791 | @xfail_on_multiple_threads # worker ids mismatch |
| 6792 | def test_debug_operator(): |
| 6793 | test_dir = os.path.dirname(os.path.abspath(__file__)) |
| 6794 | p = sp.run( |
| 6795 | ["python3", f"{test_dir}/programs/debug.py"], capture_output=True, check=True |
| 6796 | ) |
| 6797 | expected_output = """[0][foo] @Timestamp(2) +1 id=^X1MXHYYG4YM0DB900V28XN5T4W, a=Int(1), t=Int(2) |
| 6798 | [0][foo] @Timestamp(2) +1 id=^YYY4HABTRW7T8VX2Q429ZYV70W, a=Int(2), t=Int(2) |
| 6799 | [0][foo] @Timestamp(6) +1 id=^Z3QWT294JQSHPSR8KTPG9ECE4W, a=Int(10), t=Int(5) |
| 6800 | [0][foo] @Timestamp(8) +1 id=^3CZ78B48PASGNT231ZECWPER90, a=Int(3), t=Int(8) |
| 6801 | [0][foo] @Timestamp(8) +1 id=^3HN31E1PBT7YHH5PWVKTZCPRJ8, a=Int(5), t=Int(7) |
| 6802 | """ |
| 6803 | assert p.stdout.decode() == expected_output |
| 6804 | |
| 6805 | |
| 6806 | def test_table_to_stream(): |