Skip to content

Commit a741da2

Browse files
committed
lint & skipping tests
1 parent f322386 commit a741da2

File tree

3 files changed

+3
-2
lines changed

3 files changed

+3
-2
lines changed

azure_functions_worker/dispatcher.py

-1
Original file line numberDiff line numberDiff line change
@@ -165,7 +165,6 @@ async def dispatch_forever(self): # sourcery skip: swap-if-expression
165165
self._loop.set_task_factory(
166166
lambda loop, coro: ContextEnabledTask(coro, loop=loop))
167167

168-
169168
# Detach console logging before enabling GRPC channel logging
170169
logger.info('Detaching console logging.')
171170
disable_console_logging()

tests/unittests/test_dispatcher.py

+1-1
Original file line numberDiff line numberDiff line change
@@ -999,7 +999,7 @@ def test_init_with_context(self):
999999
try:
10001000
self.loop.set_task_factory(
10011001
lambda loop, coro, context=None: ContextEnabledTask(
1002-
coro, loop=loop, context=context))
1002+
coro, loop=loop, context=ctx))
10031003
except TypeError:
10041004
exception_raised = True
10051005
self.assertFalse(exception_raised)

tests/unittests/test_http_functions.py

+2
Original file line numberDiff line numberDiff line change
@@ -442,6 +442,8 @@ def check_log_hijack_current_event_loop(self, host_out: typing.List[str]):
442442
# System logs should not exist in host_out
443443
self.assertNotIn('parallelly_log_system at disguised_logger', host_out)
444444

445+
@skipIf(sys.version_info.minor < 11,
446+
"The context param is only available for 3.11+")
445447
def test_create_task_with_context(self):
446448
r = self.webhost.request('GET', 'create_task_with_context')
447449

0 commit comments

Comments
 (0)