@@ -692,98 +692,3 @@ def test_signal_on_migrate_schemas(self):
692
692
sender = mock .ANY ,
693
693
signal = schema_migrated ,
694
694
)
695
-
696
-
697
- # class SchemaMigrateMessageSignalTest(BaseTestCase):
698
- #
699
- # def setUp(self):
700
- # self.created = []
701
- # super().setUp()
702
- # self.sync_shared()
703
- #
704
- # def tearDown(self):
705
- # from django_tenants.models import TenantMixin
706
- #
707
- # connection.set_schema_to_public()
708
- #
709
- # for c in self.created:
710
- # if isinstance(c, TenantMixin):
711
- # c.delete(force_drop=True)
712
- # else:
713
- # c.delete()
714
- #
715
- # super().tearDown()
716
- #
717
- # def test_signal_on_sync_shared(self):
718
- # """
719
- # Public schema always gets migrated in the current process,
720
- # even with executor multiprocessing.
721
- # """
722
- # with catch_signal(schema_migrate_message) as handler:
723
- # self.sync_shared()
724
- #
725
- # handler.assert_called_once_with(
726
- # schema_name=get_public_schema_name(),
727
- # sender=mock.ANY,
728
- # signal=schema_migrate_message,
729
- # )
730
- #
731
- # def test_signal_on_tenant_create(self):
732
- # """
733
- # Since migrate gets called on creating of a tenant, check
734
- # the signal gets sent.
735
- # """
736
- # executor = get_executor()
737
- #
738
- # tenant = get_tenant_model()(schema_name='test')
739
- # with catch_signal(schema_migrate_message) as handler:
740
- # tenant.save()
741
- #
742
- # if executor == 'simple':
743
- # handler.assert_called_once_with(
744
- # schema_name='test',
745
- # sender=mock.ANY,
746
- # signal=schema_migrate_message
747
- # )
748
- # elif executor == 'multiprocessing':
749
- # # migrations run in a different process, therefore signal
750
- # # will get sent in a different process as well
751
- # handler.assert_not_called()
752
- #
753
- # domain = get_tenant_domain_model()(tenant=tenant, domain='something.test.com')
754
- # domain.save()
755
- # self.created = [domain, tenant]
756
- #
757
- # def test_signal_on_migrate_schemas(self):
758
- # """
759
- # Check signals are sent on running of migrate_schemas.
760
- # """
761
- # executor = get_executor()
762
- # tenant = get_tenant_model()(schema_name='test')
763
- # tenant.save()
764
- # domain = get_tenant_domain_model()(tenant=tenant, domain='something.test.com')
765
- # domain.save()
766
- #
767
- # # test the signal gets called when running migrate
768
- # with catch_signal(schema_migrate_message) as handler:
769
- # call_command('migrate_schemas', interactive=False, verbosity=0)
770
- #
771
- # if executor == 'simple':
772
- # handler.assert_has_calls([
773
- # mock.call(
774
- # schema_name=get_public_schema_name(),
775
- # sender=mock.ANY,
776
- # signal=schema_migrate_message,
777
- # ),
778
- # mock.call(
779
- # schema_name='test',
780
- # sender=mock.ANY,
781
- # signal=schema_migrate_message)
782
- # ])
783
- # elif executor == 'multiprocessing':
784
- # # public schema gets migrated in the current process, always
785
- # handler.assert_called_once_with(
786
- # schema_name=get_public_schema_name(),
787
- # sender=mock.ANY,
788
- # signal=schema_migrate_message,
789
- # )
0 commit comments