diff --git a/py/client/pydeephaven/_arrow_flight_service.py b/py/client/pydeephaven/_arrow_flight_service.py index 595de3990b7..95200aacfd4 100644 --- a/py/client/pydeephaven/_arrow_flight_service.py +++ b/py/client/pydeephaven/_arrow_flight_service.py @@ -21,7 +21,7 @@ def import_table(self, data: pa.Table) -> Table: try: if not isinstance(data, (pa.Table, pa.RecordBatch)): raise DHError("source data must be either a pa table or RecordBatch.") - ticket = self.session.get_ticket_no() + ticket = self.session.next_export_ticket_no() dh_fields = [] for f in data.schema: dh_fields.append(pa.field(name=f.name, type=f.type, metadata=map_arrow_type(f.type))) diff --git a/py/client/pydeephaven/session.py b/py/client/pydeephaven/session.py index 7341defe04b..81ac0f5acb3 100644 --- a/py/client/pydeephaven/session.py +++ b/py/client/pydeephaven/session.py @@ -335,11 +335,11 @@ def plugin_object_service(self) -> PluginObjService: def make_export_ticket(self, ticket_no=None) -> ExportTicket: if not ticket_no: - ticket_no = self.get_ticket_no() + ticket_no = self.next_export_ticket_no() ticket_bytes = ticket_no.to_bytes(4, byteorder='little', signed=True) return ExportTicket(ticket_bytes=b'e' + ticket_bytes) - def get_ticket_no(self) -> int: + def next_export_ticket_no(self) -> int: with self._r_lock: self._last_ticket += 1 if self._last_ticket == 2 ** 31 - 1: