mirrors/ruff
1
0
Fork 0
mirror of https://github.com/astral-sh/ruff.git synced 2025-10-04 07:35:01 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

Enable logging for directory-renamed test (#14533)

Browse source
This commit is contained in:
Micha Reiser 2024-11-22 17:41:46 +01:00 • committed by GitHub
parent e25e7044ba
commit e53ac7985d
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

14
crates/red_knot/tests/file_watching.rs
View file

@ -4,7 +4,6 @@ use std::io::Write;
use std::time::Duration; use std::time::Duration;
use anyhow::{anyhow, Context}; use anyhow::{anyhow, Context};
use red_knot_python_semantic::{resolve_module, ModuleName, Program, PythonVersion, SitePackages}; use red_knot_python_semantic::{resolve_module, ModuleName, Program, PythonVersion, SitePackages};
use red_knot_workspace::db::{Db, RootDatabase}; use red_knot_workspace::db::{Db, RootDatabase};
use red_knot_workspace::watch; use red_knot_workspace::watch;
@ -14,7 +13,7 @@ use red_knot_workspace::workspace::WorkspaceMetadata;
use ruff_db::files::{system_path_to_file, File, FileError}; use ruff_db::files::{system_path_to_file, File, FileError};
use ruff_db::source::source_text; use ruff_db::source::source_text;
use ruff_db::system::{OsSystem, SystemPath, SystemPathBuf}; use ruff_db::system::{OsSystem, SystemPath, SystemPathBuf};
use ruff_db::testing::setup_logging; use ruff_db::testing::{setup_logging, setup_logging_with_filter};
use ruff_db::Upcast; use ruff_db::Upcast;
struct TestCase { struct TestCase {
@ -47,6 +46,8 @@ impl TestCase {
} }
fn try_stop_watch(&mut self, timeout: Duration) -> Option<Vec<watch::ChangeEvent>> { fn try_stop_watch(&mut self, timeout: Duration) -> Option<Vec<watch::ChangeEvent>> {
tracing::debug!("Try stopping watch with timeout {:?}", timeout);
let watcher = self let watcher = self
.watcher .watcher
.take() .take()
@ -56,8 +57,11 @@ impl TestCase {
.changes_receiver .changes_receiver
.recv_timeout(timeout) .recv_timeout(timeout)
.unwrap_or_default(); .unwrap_or_default();
watcher.flush(); watcher.flush();
tracing::debug!("Flushed file watcher");
watcher.stop(); watcher.stop();
tracing::debug!("Stopping file watcher");
for event in &self.changes_receiver { for event in &self.changes_receiver {
all_events.extend(event); all_events.extend(event);
@ -600,6 +604,8 @@ fn directory_moved_to_trash() -> anyhow::Result<()> {
#[test] #[test]
fn directory_renamed() -> anyhow::Result<()> { fn directory_renamed() -> anyhow::Result<()> {
let _tracing = setup_logging_with_filter("file_watching=TRACE,red_knot=TRACE");
let mut case = setup([ let mut case = setup([
("bar.py", "import sub.a"), ("bar.py", "import sub.a"),
("sub/__init__.py", ""), ("sub/__init__.py", ""),
@ -640,6 +646,10 @@ fn directory_renamed() -> anyhow::Result<()> {
let changes = case.stop_watch(); let changes = case.stop_watch();
for event in &changes {
tracing::debug!("Event: {:?}", event);
}
case.apply_changes(changes); case.apply_changes(changes);
// `import sub.a` should no longer resolve // `import sub.a` should no longer resolve