diff --git a/data_studio_jupyter_extensions/_version.py b/data_studio_jupyter_extensions/_version.py index 87a0871908..9580e30749 100644 --- a/data_studio_jupyter_extensions/_version.py +++ b/data_studio_jupyter_extensions/_version.py @@ -1 +1 @@ -__version__ = "0.19.0" # pragma: no cover +__version__ = "0.19.1" # pragma: no cover diff --git a/data_studio_jupyter_extensions/configurables/session_manager.py b/data_studio_jupyter_extensions/configurables/session_manager.py index c5d70dc05d..53c46a0b41 100644 --- a/data_studio_jupyter_extensions/configurables/session_manager.py +++ b/data_studio_jupyter_extensions/configurables/session_manager.py @@ -111,64 +111,3 @@ async def list_sessions(self): event={"state": "Synced."}, ) return out - - # --------------------- Temporarily inline these methods until synchronizer 0.0.6 is ready - - def save(self, record: KernelRecord) -> None: - fields = { - k: v - for k, v in record.get_active_fields().items() - if k in self._table_columns - } - columns = ",".join(fields.keys()) - values_tuple = tuple(fields.values()) - if len(values_tuple) > 1: - values = str(values_tuple) - else: - values = f"('{values_tuple[0]}')" - self.cursor.execute( - f"INSERT INTO {self._table_name} ({columns}) VALUES {values}" - ) - - def update(self, record: KernelRecord) -> None: - found = False - for record_field in record.get_identifier_fields(): - record_id = getattr(record, record_field) - if record_id and self.exists(**{record_field: record_id}): - found = True - break - if not found: - raise Exception( - "No KernelRecord found in the KernelTable. " - "If this is a new record, use the `.save` method to store " - "the KernelRecord." - ) - - # Build the query for updating columns. - fields = { - k: v - for k, v in record.get_active_fields().items() - if k in self._table_columns - } - updates = [] - for key, value in fields.items(): - updates.append(f"{key}='{value}'") - update_string = ", ".join(updates) - x = f"UPDATE {self._table_name} SET {update_string} WHERE {record_field}='{record_id}';" - self.cursor.execute(x) - - def row_to_record(self, row) -> KernelRecord: - items = {field: row[field] for field in self._table_columns} - return self.kernel_record_class(**items) # type:ignore[no-any-return] - - def list(self): - self.cursor.execute(f"SELECT * FROM {self._table_name}") - rows = self.cursor.fetchall() - return [self.row_to_record(row) for row in rows] - - def get(self, **identifier) -> KernelRecord: - self.query("SELECT * FROM {table} WHERE {0}=?", **identifier) - row = self.cursor.fetchone() - if not row: - raise Exception("No match was found in database.") - return self.row_to_record(row) diff --git a/pyproject.toml b/pyproject.toml index 40f45fdebb..a09835d625 100644 --- a/pyproject.toml +++ b/pyproject.toml @@ -23,7 +23,7 @@ testpaths = [ ] [tool.tbump.version] -current = "0.19.0" +current = "0.19.1" regex = ''' (?P\d+)\.(?P\d+)\.(?P\d+) ((?Pa|b|rc|.dev)(?P\d+))? diff --git a/setup.cfg b/setup.cfg index d90f60d933..478d0bfdb5 100644 --- a/setup.cfg +++ b/setup.cfg @@ -31,7 +31,7 @@ install_requires = jupyter_client~=7.3.0 validators~=0.18.2 pycryptodome~=3.14.1 - jupyter_server_synchronizer==0.0.5 + jupyter_server_synchronizer==0.0.6 [options.entry_points] jupyter_client.kernel_provisioners = diff --git a/src/status.tsx b/src/status.tsx index a975ace501..9bd2d8ca7e 100644 --- a/src/status.tsx +++ b/src/status.tsx @@ -31,7 +31,7 @@ import { ISessionContext, ReactWidget } from '@jupyterlab/apputils'; import { TelemetryListener } from './telemetrylistener'; // This is managed by tbump config in pyproject.toml -const VERSION = '0.19.0'; +const VERSION = '0.19.1'; // Define the error states // https://github.pie.apple.com/pie-data-studio/notebook-service/blob/761d63604966db5918d2e491c0f89cce454b7f67/app/com/apple/datastudio/model/ResourceState.scala#L20 diff --git a/version b/version index 1cf0537c34..41915c7994 100644 --- a/version +++ b/version @@ -1 +1 @@ -0.19.0 +0.19.1