(py_connector_input, fs_connector_input)
| 1088 | self.next_str(item) |
| 1089 | |
| 1090 | def run_computation(py_connector_input, fs_connector_input): |
| 1091 | G.clear() |
| 1092 | write_lines(input_path, "\n".join(fs_connector_input)) |
| 1093 | table_py = pw.io.python.read( |
| 1094 | TestSubject(py_connector_input), format="raw", name="1" |
| 1095 | ) |
| 1096 | table_csv = pw.io.plaintext.read(input_path, name="2", mode="static") |
| 1097 | table_joined = table_py.join(table_csv, table_py.data == table_csv.data).select( |
| 1098 | table_py.data |
| 1099 | ) |
| 1100 | pw.io.csv.write(table_joined, output_path) |
| 1101 | run( |
| 1102 | persistence_config=pw.persistence.Config( |
| 1103 | pw.persistence.Backend.filesystem(persistent_storage_path), |
| 1104 | ) |
| 1105 | ) |
| 1106 | |
| 1107 | # We have "one" in Python connector and "one" in plaintext connector |
| 1108 | # They will form this one pair. |
no test coverage detected