Skip to content

Commit 8bc218b

Browse files
committed
fix: remove some unnecessary logging
1 parent 13e87d1 commit 8bc218b

File tree

1 file changed

+1
-6
lines changed

1 file changed

+1
-6
lines changed

dagster_sqlmesh/resource.py

Lines changed: 1 addition & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -185,9 +185,6 @@ def initialize_from_plan(self, plan: SQLMeshPlan):
185185
created_at=created_at,
186186
)
187187

188-
self.logger.debug(f"non_models: {self._non_model_names}")
189-
self.logger.debug(f"snapshots_by_name: {snapshots_by_name.keys()}")
190-
191188
# Update all of the model status that are to be updated or restated in this plan
192189
# This condition was taken from a condition found in sqlmesh's `Context`
193190
# object
@@ -252,8 +249,6 @@ def notify_queue_next(self) -> tuple[str, ModelMaterializationStatus] | None:
252249
while True:
253250
model_name_for_notification = self._sorted_dag[self._current_index]
254251

255-
self.logger.debug(f"notifying about {model_name_for_notification}")
256-
257252
if model_name_for_notification in self._non_model_names:
258253
self._current_index += 1
259254
self.logger.debug(f"skipping non-model snapshot {model_name_for_notification}")
@@ -363,7 +358,7 @@ def notify_success(
363358
output_key = get_asset_key_str(model.fqn)
364359
if self._is_testing:
365360
asset_key = dg.AssetKey(["testing", output_key])
366-
self._logger.debug(
361+
self._logger.warning(
367362
f"Generated fake asset key for testing: {asset_key.to_user_string()}"
368363
)
369364
else:

0 commit comments

Comments
 (0)