This commit is contained in:
Krishnaprasad MG 2025-11-17 18:45:02 +01:00 committed by GitHub
commit a605aa9583
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
4 changed files with 66 additions and 10 deletions

View file

@ -4,6 +4,7 @@ import threading
import traceback
import unittest
import warnings
from functools import partial
from io import StringIO
from unittest import mock
@ -2145,6 +2146,35 @@ class CaptureOnCommitCallbacksTests(TestCase):
self.assertIsInstance(raised_exception, MyException)
self.assertEqual(str(raised_exception), "robust callback")
def test_execute_robust_with_callback_as_partial(self):
class MyException(Exception):
pass
def hook():
self.callback_called = True
raise MyException("robust callback")
hook_partial = partial(hook)
with self.assertLogs("django.test", "ERROR") as cm:
with self.captureOnCommitCallbacks(execute=True) as callbacks:
transaction.on_commit(hook_partial, robust=True)
self.assertEqual(len(callbacks), 1)
self.assertIs(self.callback_called, True)
log_record = cm.records[0]
self.assertRegex(
log_record.getMessage(),
r"Error calling functools\.partial\(<function CaptureOnCommitCallbacksTests"
r"\.test_execute_robust_with_callback_as_partial\.<locals>\.hook"
r" at .+>\) in on_commit\(\) \(robust callback\)\.",
)
self.assertIsNotNone(log_record.exc_info)
raised_exception = log_record.exc_info[1]
self.assertIsInstance(raised_exception, MyException)
self.assertEqual(str(raised_exception), "robust callback")
class DisallowedDatabaseQueriesTests(SimpleTestCase):
def test_disallowed_database_connections(self):