@@ -109,8 +109,11 @@ def guarded_socket(*args, **kwargs):
109109 if "NETWORK_ATTEMPTED" in result .stdout :
110110 self .fail (f"Network access attempted despite warm cache: { result .stdout } " )
111111
112- self .assertIn ("OFFLINE_SUCCESS" , result .stdout ,
113- f"Failed to load offline:\n STDOUT: { result .stdout } \n STDERR: { result .stderr } " )
112+ self .assertIn (
113+ "OFFLINE_SUCCESS" ,
114+ result .stdout ,
115+ f"Failed to load offline:\n STDOUT: { result .stdout } \n STDERR: { result .stderr } " ,
116+ )
114117 self .assertEqual (result .returncode , 0 )
115118
116119 def test_pipeline_offline_after_subprocess_warm (self ):
@@ -134,8 +137,9 @@ def test_pipeline_offline_after_subprocess_warm(self):
134137print("WARMED")
135138"""
136139
137- result = subprocess .run ([sys .executable , "-c" , warm_script ],
138- capture_output = True , text = True , env = env , timeout = 120 )
140+ result = subprocess .run (
141+ [sys .executable , "-c" , warm_script ], capture_output = True , text = True , env = env , timeout = 120
142+ )
139143 self .assertEqual (result .returncode , 0 )
140144
141145 # Load offline
@@ -165,8 +169,9 @@ def no_socket(*args, **kwargs):
165169 exit(1)
166170"""
167171
168- result = subprocess .run ([sys .executable , "-c" , offline_script ],
169- capture_output = True , text = True , env = env , timeout = 120 )
172+ result = subprocess .run (
173+ [sys .executable , "-c" , offline_script ], capture_output = True , text = True , env = env , timeout = 120
174+ )
170175
171176 self .assertNotIn ("BLOCKED" , result .stdout , "Network access attempted" )
172177 self .assertIn ("SUCCESS" , result .stdout )
0 commit comments