Method join

python/pathway/tests/utils.py:118–122 · view source on GitHub ↗

(self, timeout=None)

Source from the content-addressed store, hash-verified

116	del self._target, self._args, self._kwargs # type: ignore
117
118	def join(self, timeout=None):
119	super().join(timeout)
120	if self._exception:
121	raise self._exception
122	return self._result
123
124
125	class UniquePortDispenser:

test_streaming_from_deltalakeFunction · 0.95

test_fs_metadata_onlyFunction · 0.95

test_clickhouse_streaming_appends_all_changesFunction · 0.95

_test_mysql_streamingFunction · 0.95

_test_mongodb_streamingFunction · 0.95

_test_mssql_streamingFunction · 0.95

_test_postgres_streamingFunction · 0.95

test_mysql_read_streaming_reflects_inserts_updates_deletesFunction · 0.95

test_mysql_read_streaming_delivers_entire_large_single_statementFunction · 0.95

test_mysql_read_streaming_composite_key_and_reordered_schemaFunction · 0.95

test_object_modifiedFunction · 0.95

test_object_deletedFunction · 0.95

no outgoing calls

test_streaming_from_deltalakeFunction · 0.76

test_fs_metadata_onlyFunction · 0.76

test_clickhouse_streaming_appends_all_changesFunction · 0.76

_test_mysql_streamingFunction · 0.76

_test_mongodb_streamingFunction · 0.76

_test_mssql_streamingFunction · 0.76

_test_postgres_streamingFunction · 0.76

test_mysql_read_streaming_reflects_inserts_updates_deletesFunction · 0.76

test_mysql_read_streaming_delivers_entire_large_single_statementFunction · 0.76

test_mysql_read_streaming_composite_key_and_reordered_schemaFunction · 0.76

test_object_modifiedFunction · 0.76

test_object_deletedFunction · 0.76