Skip to content

Commit

Permalink
tune some log messages
Browse files Browse the repository at this point in the history
  • Loading branch information
Kafonek committed Sep 28, 2023
1 parent b8cd049 commit 60dd770
Show file tree
Hide file tree
Showing 2 changed files with 5 additions and 5 deletions.
8 changes: 4 additions & 4 deletions origami/clients/rtu.py
Original file line number Diff line number Diff line change
Expand Up @@ -685,7 +685,7 @@ async def replay_unapplied_deltas(self):
async def on_kernel_status_update(self, msg: KernelStatusUpdateResponse):
"""Called when we receive a kernel_status_update_event on kernels/ channel"""
self.kernel_state = msg.data.kernel.execution_state
logger.info(f"updating Kernel state to: {self.kernel_state}")
logger.debug(f"updating Kernel state to: {self.kernel_state}")

async def on_bulk_cell_state_update(self, msg: BulkCellStateUpdateResponse):
"""Called when we receive a bulk_cell_state_update_event on kernels/ channel"""
Expand All @@ -695,7 +695,7 @@ async def on_bulk_cell_state_update(self, msg: BulkCellStateUpdateResponse):
# When we see that a cell we're monitoring has finished, resolve the Future to
# be the cell
if item.state in ['finished_with_error', 'finished_with_no_error']:
logger.info(
logger.debug(
"Cell execution for monitored cell finished",
extra={
'cell_id': item.cell_id,
Expand All @@ -722,10 +722,10 @@ async def on_bulk_cell_state_update(self, msg: BulkCellStateUpdateResponse):

async def wait_for_kernel_idle(self):
"""Wait for the kernel to be idle"""
logger.info("Waiting for Kernel to be idle")
logger.debug("Waiting for Kernel to be idle")
while self.kernel_state != 'idle':
await asyncio.sleep(0.05)
logger.info("Kernel is idle")
logger.debug("Kernel is idle")

async def new_delta_request(self, delta=FileDelta) -> FileDelta:
"""
Expand Down
2 changes: 1 addition & 1 deletion origami/notebook/builder.py
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,7 @@ def update_notebook_metadata(self, delta: NBMetadataUpdate):
def update_cell_metadata(self, delta: CellMetadataUpdate):
"""Update cell metadata using a partial update / nested path technique"""
if delta.resource_id in self.deleted_cell_ids:
logger.info(
logger.debug(
f"Skipping update_cell_metadata for deleted cell {delta.resource_id}",
extra={'delta_properties_path': delta.properties.path},
)
Expand Down

0 comments on commit 60dd770

Please sign in to comment.