diff --git a/dj_cqrs/__init__.py b/dj_cqrs/__init__.py index fe9144f..ce89692 100644 --- a/dj_cqrs/__init__.py +++ b/dj_cqrs/__init__.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import django # pragma: no cover diff --git a/dj_cqrs/_validation.py b/dj_cqrs/_validation.py index 0fba123..98af7f4 100644 --- a/dj_cqrs/_validation.py +++ b/dj_cqrs/_validation.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging from inspect import getfullargspec, isfunction diff --git a/dj_cqrs/admin.py b/dj_cqrs/admin.py index 52be6ac..5b28773 100644 --- a/dj_cqrs/admin.py +++ b/dj_cqrs/admin.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.utils.translation import gettext_lazy diff --git a/dj_cqrs/apps.py b/dj_cqrs/apps.py index 44aaeb9..cd91649 100644 --- a/dj_cqrs/apps.py +++ b/dj_cqrs/apps.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.apps import AppConfig from django.conf import settings diff --git a/dj_cqrs/constants.py b/dj_cqrs/constants.py index ed05863..b41fb9d 100644 --- a/dj_cqrs/constants.py +++ b/dj_cqrs/constants.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. ALL_BASIC_FIELDS = '__all__' diff --git a/dj_cqrs/controller/__init__.py b/dj_cqrs/controller/__init__.py index 3c8c54d..d1056b8 100644 --- a/dj_cqrs/controller/__init__.py +++ b/dj_cqrs/controller/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/dj_cqrs/controller/consumer.py b/dj_cqrs/controller/consumer.py index e2bce8c..0c428ab 100644 --- a/dj_cqrs/controller/consumer.py +++ b/dj_cqrs/controller/consumer.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import copy import logging diff --git a/dj_cqrs/controller/producer.py b/dj_cqrs/controller/producer.py index c5a4051..73b1132 100644 --- a/dj_cqrs/controller/producer.py +++ b/dj_cqrs/controller/producer.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from dj_cqrs.transport import current_transport diff --git a/dj_cqrs/correlation.py b/dj_cqrs/correlation.py index 261836d..86e250f 100644 --- a/dj_cqrs/correlation.py +++ b/dj_cqrs/correlation.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.conf import settings diff --git a/dj_cqrs/dataclasses.py b/dj_cqrs/dataclasses.py index 0164ec1..288e731 100644 --- a/dj_cqrs/dataclasses.py +++ b/dj_cqrs/dataclasses.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from dateutil.parser import parse as dateutil_parse from django.utils import timezone diff --git a/dj_cqrs/delay.py b/dj_cqrs/delay.py index 71e1300..4f1bde8 100644 --- a/dj_cqrs/delay.py +++ b/dj_cqrs/delay.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from queue import Full, PriorityQueue diff --git a/dj_cqrs/management/__init__.py b/dj_cqrs/management/__init__.py index 3c8c54d..d1056b8 100644 --- a/dj_cqrs/management/__init__.py +++ b/dj_cqrs/management/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/dj_cqrs/management/commands/__init__.py b/dj_cqrs/management/commands/__init__.py index 3c8c54d..d1056b8 100644 --- a/dj_cqrs/management/commands/__init__.py +++ b/dj_cqrs/management/commands/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/dj_cqrs/management/commands/cqrs_bulk_dump.py b/dj_cqrs/management/commands/cqrs_bulk_dump.py index fb6dad9..7141c51 100644 --- a/dj_cqrs/management/commands/cqrs_bulk_dump.py +++ b/dj_cqrs/management/commands/cqrs_bulk_dump.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import datetime import os diff --git a/dj_cqrs/management/commands/cqrs_bulk_load.py b/dj_cqrs/management/commands/cqrs_bulk_load.py index 5aceb47..e8e994d 100644 --- a/dj_cqrs/management/commands/cqrs_bulk_load.py +++ b/dj_cqrs/management/commands/cqrs_bulk_load.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os import sys diff --git a/dj_cqrs/management/commands/cqrs_consume.py b/dj_cqrs/management/commands/cqrs_consume.py index fe8cc3a..090414a 100644 --- a/dj_cqrs/management/commands/cqrs_consume.py +++ b/dj_cqrs/management/commands/cqrs_consume.py @@ -1,4 +1,4 @@ -# Copyright © 2022 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging import signal import threading diff --git a/dj_cqrs/management/commands/cqrs_dead_letters.py b/dj_cqrs/management/commands/cqrs_dead_letters.py index 5b52bf8..0abe0f4 100644 --- a/dj_cqrs/management/commands/cqrs_dead_letters.py +++ b/dj_cqrs/management/commands/cqrs_dead_letters.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import ujson from django.core.management.base import BaseCommand, CommandError diff --git a/dj_cqrs/management/commands/cqrs_deleted_diff_master.py b/dj_cqrs/management/commands/cqrs_deleted_diff_master.py index f1a616d..ad61558 100644 --- a/dj_cqrs/management/commands/cqrs_deleted_diff_master.py +++ b/dj_cqrs/management/commands/cqrs_deleted_diff_master.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys diff --git a/dj_cqrs/management/commands/cqrs_deleted_diff_replica.py b/dj_cqrs/management/commands/cqrs_deleted_diff_replica.py index 3552e45..f645370 100644 --- a/dj_cqrs/management/commands/cqrs_deleted_diff_replica.py +++ b/dj_cqrs/management/commands/cqrs_deleted_diff_replica.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import ujson from django.core.exceptions import FieldError diff --git a/dj_cqrs/management/commands/cqrs_deleted_sync_replica.py b/dj_cqrs/management/commands/cqrs_deleted_sync_replica.py index 3eb963c..cd35352 100644 --- a/dj_cqrs/management/commands/cqrs_deleted_sync_replica.py +++ b/dj_cqrs/management/commands/cqrs_deleted_sync_replica.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys diff --git a/dj_cqrs/management/commands/cqrs_diff_master.py b/dj_cqrs/management/commands/cqrs_diff_master.py index 825c1ab..6d49859 100644 --- a/dj_cqrs/management/commands/cqrs_diff_master.py +++ b/dj_cqrs/management/commands/cqrs_diff_master.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import ujson from django.core.exceptions import FieldError diff --git a/dj_cqrs/management/commands/cqrs_diff_replica.py b/dj_cqrs/management/commands/cqrs_diff_replica.py index 10b31dc..00644ff 100644 --- a/dj_cqrs/management/commands/cqrs_diff_replica.py +++ b/dj_cqrs/management/commands/cqrs_diff_replica.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys diff --git a/dj_cqrs/management/commands/cqrs_diff_sync.py b/dj_cqrs/management/commands/cqrs_diff_sync.py index c875434..9397315 100644 --- a/dj_cqrs/management/commands/cqrs_diff_sync.py +++ b/dj_cqrs/management/commands/cqrs_diff_sync.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys diff --git a/dj_cqrs/management/commands/cqrs_sync.py b/dj_cqrs/management/commands/cqrs_sync.py index 640c4b8..cca0cdd 100644 --- a/dj_cqrs/management/commands/cqrs_sync.py +++ b/dj_cqrs/management/commands/cqrs_sync.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import datetime import sys diff --git a/dj_cqrs/management/utils.py b/dj_cqrs/management/utils.py index 4e21153..e113b2c 100644 --- a/dj_cqrs/management/utils.py +++ b/dj_cqrs/management/utils.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. def batch_qs(qs, batch_size=10000): diff --git a/dj_cqrs/managers.py b/dj_cqrs/managers.py index 04fab7e..4b98e80 100644 --- a/dj_cqrs/managers.py +++ b/dj_cqrs/managers.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging diff --git a/dj_cqrs/metas.py b/dj_cqrs/metas.py index ecbfa7b..6e7ea83 100644 --- a/dj_cqrs/metas.py +++ b/dj_cqrs/metas.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.db.models import base diff --git a/dj_cqrs/mixins.py b/dj_cqrs/mixins.py index 7aedd32..c9a2536 100644 --- a/dj_cqrs/mixins.py +++ b/dj_cqrs/mixins.py @@ -1,4 +1,4 @@ -# Copyright © 2024 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging diff --git a/dj_cqrs/registries.py b/dj_cqrs/registries.py index ade5150..cd19b7d 100644 --- a/dj_cqrs/registries.py +++ b/dj_cqrs/registries.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging diff --git a/dj_cqrs/signals.py b/dj_cqrs/signals.py index a9e9cd1..7dbdb1c 100644 --- a/dj_cqrs/signals.py +++ b/dj_cqrs/signals.py @@ -1,4 +1,4 @@ -# Copyright © 2024 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging diff --git a/dj_cqrs/state.py b/dj_cqrs/state.py index 0a575af..9b4a059 100644 --- a/dj_cqrs/state.py +++ b/dj_cqrs/state.py @@ -1,4 +1,4 @@ -# Copyright © 2024 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import threading diff --git a/dj_cqrs/tracker.py b/dj_cqrs/tracker.py index 2dcf40d..bf200fa 100644 --- a/dj_cqrs/tracker.py +++ b/dj_cqrs/tracker.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from model_utils import FieldTracker from model_utils.tracker import FieldInstanceTracker diff --git a/dj_cqrs/transport/__init__.py b/dj_cqrs/transport/__init__.py index fa5a435..4cece33 100644 --- a/dj_cqrs/transport/__init__.py +++ b/dj_cqrs/transport/__init__.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.conf import settings from django.utils.module_loading import import_string diff --git a/dj_cqrs/transport/base.py b/dj_cqrs/transport/base.py index 8918ceb..a57cff2 100644 --- a/dj_cqrs/transport/base.py +++ b/dj_cqrs/transport/base.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. class BaseTransport: diff --git a/dj_cqrs/transport/kombu.py b/dj_cqrs/transport/kombu.py index 415e428..3f2cef8 100644 --- a/dj_cqrs/transport/kombu.py +++ b/dj_cqrs/transport/kombu.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging diff --git a/dj_cqrs/transport/mixins.py b/dj_cqrs/transport/mixins.py index 3ec4974..624aff7 100644 --- a/dj_cqrs/transport/mixins.py +++ b/dj_cqrs/transport/mixins.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging diff --git a/dj_cqrs/transport/mock.py b/dj_cqrs/transport/mock.py index 27eac01..aebdf55 100644 --- a/dj_cqrs/transport/mock.py +++ b/dj_cqrs/transport/mock.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from dj_cqrs.transport import BaseTransport diff --git a/dj_cqrs/transport/rabbit_mq.py b/dj_cqrs/transport/rabbit_mq.py index b4ea68e..49248fc 100644 --- a/dj_cqrs/transport/rabbit_mq.py +++ b/dj_cqrs/transport/rabbit_mq.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging import time diff --git a/dj_cqrs/utils.py b/dj_cqrs/utils.py index ff80eb0..be2b4ed 100644 --- a/dj_cqrs/utils.py +++ b/dj_cqrs/utils.py @@ -1,4 +1,4 @@ -# Copyright © 2024 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging from collections import defaultdict diff --git a/docs/lifecycle.md b/docs/lifecycle.md index 2f44c36..c5c7bc4 100644 --- a/docs/lifecycle.md +++ b/docs/lifecycle.md @@ -127,7 +127,7 @@ Dumps all dead letters to stdout. ``` console $ python manage.py cqrs_dead_letters dump -{"signal_type":"SAVE","cqrs_id":"example","instance_data":{"id":1,"cqrs_revision":0,"cqrs_updated":"2021-04-30 11:50:05.164341+00:00"},"previous_data":null,"instance_pk":135,"correlation_id":null,"retries":30,"expires":"2021-05-01T11:50:00+00:00"} +{"signal_type":"SAVE","cqrs_id":"example","instance_data":{"id":1,"cqrs_revision":0,"cqrs_updated":"2025-04-30 11:50:05.164341+00:00"},"previous_data":null,"instance_pk":135,"correlation_id":null,"retries":30,"expires":"2025-05-01T11:50:00+00:00"} ``` ### Retry @@ -138,7 +138,7 @@ Retry all dead letters. Message body retries and expires fields are downgraded. $ python manage.py cqrs_dead_letters retry Total dead letters: 1 Retrying: 1/1 -{"signal_type":"SAVE","cqrs_id":"example","instance_data":{"id":1,"cqrs_revision":0,"cqrs_updated":"2021-04-30 11:50:05.164341+00:00"},"previous_data":null,"instance_pk":135,"correlation_id":null,"retries":0,"expires":"2021-05-02T12:30:00+00:00"} +{"signal_type":"SAVE","cqrs_id":"example","instance_data":{"id":1,"cqrs_revision":0,"cqrs_updated":"2025-04-30 11:50:05.164341+00:00"},"previous_data":null,"instance_pk":135,"correlation_id":null,"retries":0,"expires":"2025-05-02T12:30:00+00:00"} ``` ### Purge diff --git a/examples/demo_project/master_service/__init__.py b/examples/demo_project/master_service/__init__.py index 3c8c54d..d1056b8 100644 --- a/examples/demo_project/master_service/__init__.py +++ b/examples/demo_project/master_service/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/examples/demo_project/master_service/app/asgi.py b/examples/demo_project/master_service/app/asgi.py index 29ab57e..2f0255c 100644 --- a/examples/demo_project/master_service/app/asgi.py +++ b/examples/demo_project/master_service/app/asgi.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. """ ASGI config for master_service project. diff --git a/examples/demo_project/master_service/app/migrations/0001_initial.py b/examples/demo_project/master_service/app/migrations/0001_initial.py index d44735e..c954370 100644 --- a/examples/demo_project/master_service/app/migrations/0001_initial.py +++ b/examples/demo_project/master_service/app/migrations/0001_initial.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import django.contrib.auth.validators import django.utils.timezone diff --git a/examples/demo_project/master_service/app/migrations/0002_fixtures.py b/examples/demo_project/master_service/app/migrations/0002_fixtures.py index c49f001..ca9caba 100644 --- a/examples/demo_project/master_service/app/migrations/0002_fixtures.py +++ b/examples/demo_project/master_service/app/migrations/0002_fixtures.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.db import migrations diff --git a/examples/demo_project/master_service/app/models.py b/examples/demo_project/master_service/app/models.py index 662293d..30e5b87 100644 --- a/examples/demo_project/master_service/app/models.py +++ b/examples/demo_project/master_service/app/models.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.contrib.auth.models import AbstractUser from django.db import models diff --git a/examples/demo_project/master_service/app/serializers.py b/examples/demo_project/master_service/app/serializers.py index 0561125..e34d37a 100644 --- a/examples/demo_project/master_service/app/serializers.py +++ b/examples/demo_project/master_service/app/serializers.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from rest_framework import serializers from app.models import Purchase diff --git a/examples/demo_project/master_service/app/settings.py b/examples/demo_project/master_service/app/settings.py index f716384..2a05e7c 100644 --- a/examples/demo_project/master_service/app/settings.py +++ b/examples/demo_project/master_service/app/settings.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from pathlib import Path diff --git a/examples/demo_project/master_service/app/urls.py b/examples/demo_project/master_service/app/urls.py index 4aa5120..f74be9b 100644 --- a/examples/demo_project/master_service/app/urls.py +++ b/examples/demo_project/master_service/app/urls.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.urls import path from app.views import ( diff --git a/examples/demo_project/master_service/app/views.py b/examples/demo_project/master_service/app/views.py index 521f85b..6a41bac 100644 --- a/examples/demo_project/master_service/app/views.py +++ b/examples/demo_project/master_service/app/views.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.http import HttpResponseNotAllowed from django.shortcuts import get_object_or_404, redirect, render from django.views.decorators.http import require_http_methods diff --git a/examples/demo_project/master_service/app/wsgi.py b/examples/demo_project/master_service/app/wsgi.py index da8e3d3..2200f50 100644 --- a/examples/demo_project/master_service/app/wsgi.py +++ b/examples/demo_project/master_service/app/wsgi.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. """ WSGI config for master_service project. diff --git a/examples/demo_project/replica_service/app/migrations/0001_initial.py b/examples/demo_project/replica_service/app/migrations/0001_initial.py index e17ee85..627bb5c 100644 --- a/examples/demo_project/replica_service/app/migrations/0001_initial.py +++ b/examples/demo_project/replica_service/app/migrations/0001_initial.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import django.contrib.auth.validators import django.utils.timezone diff --git a/examples/demo_project/replica_service/app/models.py b/examples/demo_project/replica_service/app/models.py index 1fd34b8..6eb3e03 100644 --- a/examples/demo_project/replica_service/app/models.py +++ b/examples/demo_project/replica_service/app/models.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.contrib.auth.models import AbstractUser from django.core.cache import cache from django.db import models diff --git a/examples/demo_project/replica_service/app/settings.py b/examples/demo_project/replica_service/app/settings.py index 35e042b..b1716c7 100644 --- a/examples/demo_project/replica_service/app/settings.py +++ b/examples/demo_project/replica_service/app/settings.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from pathlib import Path diff --git a/examples/demo_project/replica_service/app/urls.py b/examples/demo_project/replica_service/app/urls.py index 852367d..f247b8e 100644 --- a/examples/demo_project/replica_service/app/urls.py +++ b/examples/demo_project/replica_service/app/urls.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.urls import path from app.views import main_page_view diff --git a/examples/demo_project/replica_service/app/views.py b/examples/demo_project/replica_service/app/views.py index c56d6de..4b3cd5a 100644 --- a/examples/demo_project/replica_service/app/views.py +++ b/examples/demo_project/replica_service/app/views.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.core.cache import cache from django.shortcuts import render diff --git a/integration_tests/__init__.py b/integration_tests/__init__.py index 3c8c54d..d1056b8 100644 --- a/integration_tests/__init__.py +++ b/integration_tests/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/integration_tests/manage.py b/integration_tests/manage.py index 584d93e..eb40876 100755 --- a/integration_tests/manage.py +++ b/integration_tests/manage.py @@ -1,6 +1,6 @@ #!/usr/bin/env python -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os import sys diff --git a/integration_tests/master_settings.py b/integration_tests/master_settings.py index a59908c..b589c16 100644 --- a/integration_tests/master_settings.py +++ b/integration_tests/master_settings.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os diff --git a/integration_tests/replica_settings.py b/integration_tests/replica_settings.py index 0649041..17b8bee 100644 --- a/integration_tests/replica_settings.py +++ b/integration_tests/replica_settings.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os diff --git a/integration_tests/replica_wsgi.py b/integration_tests/replica_wsgi.py index 635d0c2..1e4e1d3 100644 --- a/integration_tests/replica_wsgi.py +++ b/integration_tests/replica_wsgi.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os diff --git a/integration_tests/tests/__init__.py b/integration_tests/tests/__init__.py index 3c8c54d..d1056b8 100644 --- a/integration_tests/tests/__init__.py +++ b/integration_tests/tests/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/integration_tests/tests/conftest.py b/integration_tests/tests/conftest.py index 7db7195..754f100 100644 --- a/integration_tests/tests/conftest.py +++ b/integration_tests/tests/conftest.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import psycopg2 import pytest diff --git a/integration_tests/tests/test_asynchronous_consuming.py b/integration_tests/tests/test_asynchronous_consuming.py index c7e6fee..f78e876 100644 --- a/integration_tests/tests/test_asynchronous_consuming.py +++ b/integration_tests/tests/test_asynchronous_consuming.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/integration_tests/tests/test_bulk_operations.py b/integration_tests/tests/test_bulk_operations.py index abe8347..58b0a89 100644 --- a/integration_tests/tests/test_bulk_operations.py +++ b/integration_tests/tests/test_bulk_operations.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/integration_tests/tests/test_dead_letter.py b/integration_tests/tests/test_dead_letter.py index b6cb42a..b0766b3 100644 --- a/integration_tests/tests/test_dead_letter.py +++ b/integration_tests/tests/test_dead_letter.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import json diff --git a/integration_tests/tests/test_single_basic_instance.py b/integration_tests/tests/test_single_basic_instance.py index 0c621da..0eafa86 100644 --- a/integration_tests/tests/test_single_basic_instance.py +++ b/integration_tests/tests/test_single_basic_instance.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest from django.utils.timezone import now diff --git a/integration_tests/tests/test_sync_to_a_certain_service.py b/integration_tests/tests/test_sync_to_a_certain_service.py index 10bab7d..d8567bc 100644 --- a/integration_tests/tests/test_sync_to_a_certain_service.py +++ b/integration_tests/tests/test_sync_to_a_certain_service.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/integration_tests/tests/utils.py b/integration_tests/tests/utils.py index 942f6e2..1430657 100644 --- a/integration_tests/tests/utils.py +++ b/integration_tests/tests/utils.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import time diff --git a/mkdocs.yml b/mkdocs.yml index d13023f..0c7bff8 100644 --- a/mkdocs.yml +++ b/mkdocs.yml @@ -3,7 +3,7 @@ site_url: https://github.com/cloudblue/django-cqrs repo_name: cloudblue/django-cqrs repo_url: https://github.com/cloudblue/django-cqrs edit_uri: "" -copyright: Copyright © 2023 Ingram Micro. All Rights Reserved. +copyright: Copyright © 2025 CloudBlue Micro. All Rights Reserved. extra: generator: false social: diff --git a/requirements/docs.txt b/requirements/docs.txt index 1f6db68..b47788c 100644 --- a/requirements/docs.txt +++ b/requirements/docs.txt @@ -1,4 +1,4 @@ -certifi==2023.5.7 ; python_version >= "3.8" and python_version < "4" +certifi==2025.5.7 ; python_version >= "3.8" and python_version < "4" charset-normalizer==3.1.0 ; python_version >= "3.8" and python_version < "4" click==8.1.3 ; python_version >= "3.8" and python_version < "4" colorama==0.4.6 ; python_version >= "3.8" and python_version < "4" @@ -24,7 +24,7 @@ pymdown-extensions==10.0.1 ; python_version >= "3.8" and python_version < "4" python-dateutil==2.8.2 ; python_version >= "3.8" and python_version < "4" pyyaml-env-tag==0.1 ; python_version >= "3.8" and python_version < "4" pyyaml==6.0 ; python_version >= "3.8" and python_version < "4" -regex==2023.5.5 ; python_version >= "3.8" and python_version < "4" +regex==2025.5.5 ; python_version >= "3.8" and python_version < "4" requests==2.31.0 ; python_version >= "3.8" and python_version < "4" six==1.16.0 ; python_version >= "3.8" and python_version < "4" termcolor==2.3.0 ; python_version >= "3.8" and python_version < "4" diff --git a/tests/__init__.py b/tests/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/__init__.py +++ b/tests/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/conftest.py b/tests/conftest.py index 992cfa7..07f3fba 100644 --- a/tests/conftest.py +++ b/tests/conftest.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from copy import deepcopy diff --git a/tests/dj/__init__.py b/tests/dj/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/dj/__init__.py +++ b/tests/dj/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/dj/settings.py b/tests/dj/settings.py index c13c85b..dc71179 100644 --- a/tests/dj/settings.py +++ b/tests/dj/settings.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os diff --git a/tests/dj/transport.py b/tests/dj/transport.py index ed0146b..857641b 100644 --- a/tests/dj/transport.py +++ b/tests/dj/transport.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os diff --git a/tests/dj/urls.py b/tests/dj/urls.py index cdb38a6..f298732 100644 --- a/tests/dj/urls.py +++ b/tests/dj/urls.py @@ -1,3 +1,3 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. urlpatterns = [] diff --git a/tests/dj_master/__init__.py b/tests/dj_master/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/dj_master/__init__.py +++ b/tests/dj_master/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/dj_master/management/__init__.py b/tests/dj_master/management/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/dj_master/management/__init__.py +++ b/tests/dj_master/management/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/dj_master/management/commands/__init__.py b/tests/dj_master/management/commands/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/dj_master/management/commands/__init__.py +++ b/tests/dj_master/management/commands/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/dj_master/management/commands/bulk_demo.py b/tests/dj_master/management/commands/bulk_demo.py index b862bf2..0413cf5 100644 --- a/tests/dj_master/management/commands/bulk_demo.py +++ b/tests/dj_master/management/commands/bulk_demo.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import random diff --git a/tests/dj_master/models.py b/tests/dj_master/models.py index d8f5a38..f938704 100644 --- a/tests/dj_master/models.py +++ b/tests/dj_master/models.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.contrib.contenttypes.fields import GenericForeignKey from django.contrib.contenttypes.models import ContentType diff --git a/tests/dj_master/serializers.py b/tests/dj_master/serializers.py index 71d7bf9..a3da09f 100644 --- a/tests/dj_master/serializers.py +++ b/tests/dj_master/serializers.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from rest_framework.serializers import CharField, ModelSerializer diff --git a/tests/dj_replica/__init__.py b/tests/dj_replica/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/dj_replica/__init__.py +++ b/tests/dj_replica/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/dj_replica/models.py b/tests/dj_replica/models.py index 4a7b6c9..67b55c2 100644 --- a/tests/dj_replica/models.py +++ b/tests/dj_replica/models.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.db import DatabaseError, models diff --git a/tests/test_admin.py b/tests/test_admin.py index f9611d7..717b3e6 100644 --- a/tests/test_admin.py +++ b/tests/test_admin.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest from django.contrib import admin diff --git a/tests/test_commands/__init__.py b/tests/test_commands/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/test_commands/__init__.py +++ b/tests/test_commands/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/test_commands/test_bulk_dump.py b/tests/test_commands/test_bulk_dump.py index 20c1d55..a44334e 100644 --- a/tests/test_commands/test_bulk_dump.py +++ b/tests/test_commands/test_bulk_dump.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest import ujson diff --git a/tests/test_commands/test_bulk_flow.py b/tests/test_commands/test_bulk_flow.py index 6751eb6..4534294 100644 --- a/tests/test_commands/test_bulk_flow.py +++ b/tests/test_commands/test_bulk_flow.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest from django.core.management import call_command diff --git a/tests/test_commands/test_bulk_load.py b/tests/test_commands/test_bulk_load.py index c8b3be6..f7e7d0d 100644 --- a/tests/test_commands/test_bulk_load.py +++ b/tests/test_commands/test_bulk_load.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/tests/test_commands/test_consume.py b/tests/test_commands/test_consume.py index 489385e..2de0740 100644 --- a/tests/test_commands/test_consume.py +++ b/tests/test_commands/test_consume.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import threading from importlib import import_module, reload diff --git a/tests/test_commands/test_dead_letters.py b/tests/test_commands/test_dead_letters.py index 3dcfc87..b6b4242 100644 --- a/tests/test_commands/test_dead_letters.py +++ b/tests/test_commands/test_dead_letters.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from datetime import datetime, timezone @@ -58,7 +58,7 @@ def test_handle_retry(settings, capsys, mocker): method_frame = mocker.MagicMock() method_frame.delivery_tag = 12 - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_now) message = { 'signal_type': SignalType.SAVE, @@ -67,7 +67,7 @@ def test_handle_retry(settings, capsys, mocker): 'instance_pk': 1, 'previous_data': None, 'correlation_id': None, - 'expires': '2020-01-01T00:00:00+00:00', + 'expires': '2025-01-01T00:00:00+00:00', 'retries': 30, } consumer_generator = (v for v in [(method_frame, None, ujson.dumps(message))]) @@ -82,7 +82,7 @@ def test_handle_retry(settings, capsys, mocker): produce_message = ujson.loads(produce_kwargs['body']) assert produce_message['instance_data'] == message['instance_data'] - assert produce_message['expires'] == '2020-01-02T00:00:00+00:00' + assert produce_message['expires'] == '2025-01-02T00:00:00+00:00' assert produce_message['retries'] == 0 captured = capsys.readouterr() @@ -90,7 +90,7 @@ def test_handle_retry(settings, capsys, mocker): assert total_msg == 'Total dead letters: 1' assert retrying_msg == 'Retrying: 1/1' - assert '2020-01-02T00:00:00+00:00' in body_msg + assert '2025-01-02T00:00:00+00:00' in body_msg assert channel.basic_nack.call_count == 1 assert channel.basic_nack.call_args[0][0] == 12 diff --git a/tests/test_commands/test_deleted_diff_master.py b/tests/test_commands/test_deleted_diff_master.py index 30c80a9..cc209bb 100644 --- a/tests/test_commands/test_deleted_diff_master.py +++ b/tests/test_commands/test_deleted_diff_master.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys from io import StringIO diff --git a/tests/test_commands/test_deleted_diff_replica.py b/tests/test_commands/test_deleted_diff_replica.py index f1cbf03..852bf59 100644 --- a/tests/test_commands/test_deleted_diff_replica.py +++ b/tests/test_commands/test_deleted_diff_replica.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest import ujson diff --git a/tests/test_commands/test_deleted_sync_replica.py b/tests/test_commands/test_deleted_sync_replica.py index be98ab5..6e6c525 100644 --- a/tests/test_commands/test_deleted_sync_replica.py +++ b/tests/test_commands/test_deleted_sync_replica.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys from io import StringIO diff --git a/tests/test_commands/test_diff_master.py b/tests/test_commands/test_diff_master.py index 244dafb..37ab43d 100644 --- a/tests/test_commands/test_diff_master.py +++ b/tests/test_commands/test_diff_master.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest import ujson diff --git a/tests/test_commands/test_diff_replica.py b/tests/test_commands/test_diff_replica.py index 8793944..70e830f 100644 --- a/tests/test_commands/test_diff_replica.py +++ b/tests/test_commands/test_diff_replica.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys from io import StringIO diff --git a/tests/test_commands/test_diff_sync.py b/tests/test_commands/test_diff_sync.py index eb8db98..bd33987 100644 --- a/tests/test_commands/test_diff_sync.py +++ b/tests/test_commands/test_diff_sync.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import sys from io import StringIO diff --git a/tests/test_commands/test_sync.py b/tests/test_commands/test_sync.py index 989b10a..7489a76 100644 --- a/tests/test_commands/test_sync.py +++ b/tests/test_commands/test_sync.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest from django.core.management import CommandError, call_command diff --git a/tests/test_commands/utils.py b/tests/test_commands/utils.py index 0a8f940..eeef509 100644 --- a/tests/test_commands/utils.py +++ b/tests/test_commands/utils.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import os diff --git a/tests/test_controller.py b/tests/test_controller.py index 95053cc..a1c1e7a 100644 --- a/tests/test_controller.py +++ b/tests/test_controller.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest from django.conf import settings diff --git a/tests/test_correlation.py b/tests/test_correlation.py index 461c97c..960efd1 100644 --- a/tests/test_correlation.py +++ b/tests/test_correlation.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from importlib import import_module, reload diff --git a/tests/test_dataclasses.py b/tests/test_dataclasses.py index 11ac227..f1ecc3b 100644 --- a/tests/test_dataclasses.py +++ b/tests/test_dataclasses.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from datetime import datetime, timezone @@ -21,11 +21,11 @@ def test_transport_payload_infinite_expires(): def test_transport_payload_without_expires(mocker, settings): - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_now) settings.CQRS['master']['CQRS_MESSAGE_TTL'] = 10 - expected_expires = datetime(2020, 1, 1, second=10, tzinfo=timezone.utc) + expected_expires = datetime(2025, 1, 1, second=10, tzinfo=timezone.utc) payload = TransportPayload.from_message( { diff --git a/tests/test_delay.py b/tests/test_delay.py index b6ca556..e2016fe 100644 --- a/tests/test_delay.py +++ b/tests/test_delay.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from datetime import datetime, timedelta, timezone from queue import Full @@ -9,7 +9,7 @@ def test_delay_message(mocker): - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) eta = fake_now + timedelta(seconds=10) mocker.patch('django.utils.timezone.now', return_value=fake_now) @@ -18,12 +18,12 @@ def test_delay_message(mocker): assert delay_message.delivery_tag == 1 assert delay_message.payload == {'test': 'data'} - expected_eta = datetime(2020, 1, 1, second=10, tzinfo=timezone.utc) + expected_eta = datetime(2025, 1, 1, second=10, tzinfo=timezone.utc) assert delay_message.eta == expected_eta def test_delay_queue_put(): - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) delay_message = DelayMessage(1, {'test': 'data'}, fake_now) delay_queue = DelayQueue() @@ -36,7 +36,7 @@ def test_delay_queue_put(): def test_delay_queue_put_same_eta(): - eta = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + eta = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) delay_messages = [DelayMessage(delivery_tag, None, eta) for delivery_tag in range(10)] delay_queue = DelayQueue() @@ -48,7 +48,7 @@ def test_delay_queue_put_same_eta(): def test_delay_queue_put_full(): - eta = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + eta = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) delay_queue = DelayQueue(max_size=1) delay_queue.put( @@ -64,7 +64,7 @@ def test_delay_queue_put_full(): def test_delay_queue_get_ready(mocker): - fake_put_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_put_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_put_now) delay_queue = DelayQueue() @@ -76,7 +76,7 @@ def test_delay_queue_get_ready(mocker): delay_messages.append(delay_message) mocker.stopall() - fake_get_ready_now = datetime(2020, 1, 1, second=3, tzinfo=timezone.utc) + fake_get_ready_now = datetime(2025, 1, 1, second=3, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_get_ready_now) ready_messages = list(delay_queue.get_ready()) diff --git a/tests/test_flow.py b/tests/test_flow.py index cf7beca..d4483a2 100644 --- a/tests/test_flow.py +++ b/tests/test_flow.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest from django.db import transaction diff --git a/tests/test_master/__init__.py b/tests/test_master/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/test_master/__init__.py +++ b/tests/test_master/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/test_master/test_mixin.py b/tests/test_master/test_mixin.py index 726a7fa..d66b811 100644 --- a/tests/test_master/test_mixin.py +++ b/tests/test_master/test_mixin.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from datetime import timedelta from time import sleep diff --git a/tests/test_master/test_signals.py b/tests/test_master/test_signals.py index d27ca9f..bdc2bc9 100644 --- a/tests/test_master/test_signals.py +++ b/tests/test_master/test_signals.py @@ -1,4 +1,4 @@ -# Copyright © 2024 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from datetime import datetime, timezone @@ -35,11 +35,11 @@ def test_post_save_create(mocker): @pytest.mark.django_db(transaction=True) def test_post_save_create_with_retry_fields(settings, mocker): - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_now) settings.CQRS['master']['CQRS_MESSAGE_TTL'] = 10 - expected_expires = datetime(2020, 1, 1, second=10, tzinfo=timezone.utc) + expected_expires = datetime(2025, 1, 1, second=10, tzinfo=timezone.utc) publisher_mock = mocker.patch('dj_cqrs.controller.producer.produce') models.SimplestModel.objects.create(id=1) @@ -101,11 +101,11 @@ def test_post_save_instance_doesnt_exist(caplog): def test_post_save_delete_with_retry_fields(settings, mocker): m = models.SimplestModel.objects.create(id=1) - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_now) settings.CQRS['master']['CQRS_MESSAGE_TTL'] = 10 - expected_expires = datetime(2020, 1, 1, second=10, tzinfo=timezone.utc) + expected_expires = datetime(2025, 1, 1, second=10, tzinfo=timezone.utc) publisher_mock = mocker.patch('dj_cqrs.controller.producer.produce') m.delete() diff --git a/tests/test_metas.py b/tests/test_metas.py index 714c788..acade5b 100644 --- a/tests/test_metas.py +++ b/tests/test_metas.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/tests/test_registries.py b/tests/test_registries.py index 0c10499..7661bd1 100644 --- a/tests/test_registries.py +++ b/tests/test_registries.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/tests/test_replica/__init__.py b/tests/test_replica/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/test_replica/__init__.py +++ b/tests/test_replica/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/test_replica/test_factory.py b/tests/test_replica/test_factory.py index 09def47..965f0f5 100644 --- a/tests/test_replica/test_factory.py +++ b/tests/test_replica/test_factory.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/tests/test_replica/test_mixin.py b/tests/test_replica/test_mixin.py index cdb8cc8..d44c2f8 100644 --- a/tests/test_replica/test_mixin.py +++ b/tests/test_replica/test_mixin.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest from django.conf import settings diff --git a/tests/test_transport/__init__.py b/tests/test_transport/__init__.py index 3c8c54d..d1056b8 100644 --- a/tests/test_transport/__init__.py +++ b/tests/test_transport/__init__.py @@ -1 +1 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. diff --git a/tests/test_transport/test_base.py b/tests/test_transport/test_base.py index 5f48de3..ea42e3c 100644 --- a/tests/test_transport/test_base.py +++ b/tests/test_transport/test_base.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import pytest diff --git a/tests/test_transport/test_kombu.py b/tests/test_transport/test_kombu.py index 0f86d64..cef9a2d 100644 --- a/tests/test_transport/test_kombu.py +++ b/tests/test_transport/test_kombu.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging from importlib import import_module, reload diff --git a/tests/test_transport/test_mock.py b/tests/test_transport/test_mock.py index 920f9a3..acbca73 100644 --- a/tests/test_transport/test_mock.py +++ b/tests/test_transport/test_mock.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from dj_cqrs.transport.mock import TransportMock diff --git a/tests/test_transport/test_rabbit_mq.py b/tests/test_transport/test_rabbit_mq.py index b94283b..4c84ee6 100644 --- a/tests/test_transport/test_rabbit_mq.py +++ b/tests/test_transport/test_rabbit_mq.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. import logging from datetime import datetime, timedelta, timezone diff --git a/tests/test_utils.py b/tests/test_utils.py index 0c7c838..1f77878 100644 --- a/tests/test_utils.py +++ b/tests/test_utils.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from datetime import ( date, @@ -27,7 +27,7 @@ def test_get_message_expiration_dt_fixed(mocker, settings): settings.CQRS['master']['CQRS_MESSAGE_TTL'] = 3600 - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_now) result = get_message_expiration_dt() @@ -37,7 +37,7 @@ def test_get_message_expiration_dt_fixed(mocker, settings): def test_get_message_expiration_dt_fixed_from_parameter(mocker, settings): - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_now) result = get_message_expiration_dt(message_ttl=2200) @@ -48,7 +48,7 @@ def test_get_message_expiration_dt_fixed_from_parameter(mocker, settings): def test_get_message_expiration_dt_infinite(mocker, settings): settings.CQRS['master']['CQRS_MESSAGE_TTL'] = None - fake_now = datetime(2020, 1, 1, second=0, tzinfo=timezone.utc) + fake_now = datetime(2025, 1, 1, second=0, tzinfo=timezone.utc) mocker.patch('django.utils.timezone.now', return_value=fake_now) result = get_message_expiration_dt() @@ -85,8 +85,8 @@ def test_get_messaged_prefetch_count_per_worker_with_delay_queue(settings): ( (None, None), (1, 1), - (datetime(2022, 1, 1, second=0, tzinfo=timezone.utc), '2022-01-01 00:00:00+00:00'), - (date(2022, 2, 1), '2022-02-01'), + (datetime(2025, 1, 1, second=0, tzinfo=timezone.utc), '2025-01-01 00:00:00+00:00'), + (date(2025, 2, 1), '2025-02-01'), (UUID('0419d87b-d477-44e4-82c4-310f56faa3c7'), '0419d87b-d477-44e4-82c4-310f56faa3c7'), ('abc', 'abc'), ), diff --git a/tests/test_validation.py b/tests/test_validation.py index de47a66..25adb67 100644 --- a/tests/test_validation.py +++ b/tests/test_validation.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from unittest.mock import MagicMock diff --git a/tests/utils.py b/tests/utils.py index d45f8f5..bd2546f 100644 --- a/tests/utils.py +++ b/tests/utils.py @@ -1,4 +1,4 @@ -# Copyright © 2023 Ingram Micro Inc. All rights reserved. +# Copyright © 2025 CloudBlue Micro Inc. All rights reserved. from django.db import DatabaseError