This is an automated email from the ASF dual-hosted git repository.
potiuk pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/airflow.git
from 5faa2414098 Move dag cycle checking logic inside the task SDK dag
class (#53934)
add 46410657253 AIP-82: Add RedisPubSubMessageQueueProvider (#53556)
No new revisions were added by this update.
Summary of changes:
.../attempt=1.log | 0
providers/redis/docs/index.rst | 1 +
providers/redis/docs/message-queues.rst | 72 ++++++++++++++++++++++
providers/redis/provider.yaml | 3 +
providers/redis/pyproject.toml | 8 +++
.../airflow/providers/redis/get_provider_info.py | 1 +
.../airflow/providers/redis/queues}/__init__.py | 0
.../src/airflow/providers/redis/queues/redis.py} | 51 +++++++--------
.../tests/integration/redis/queues}/__init__.py | 0
.../queues/test_redis_pubsub_message_queue.py | 60 ++++++++++++++++++
.../redis/example_dag_message_queue_trigger.py} | 10 +--
.../redis/tests/unit/redis/queues}/__init__.py | 0
.../tests/unit/redis/queues/test_redis.py} | 47 ++++++--------
13 files changed, 189 insertions(+), 64 deletions(-)
copy airflow-core/src/airflow/_vendor/__init__.py =>
providers/redis/any/dag_id=dag_for_testing_redis_task_handler/run_id=test/task_id=task_for_testing_redis_log_handler/attempt=1.log
(100%)
create mode 100644 providers/redis/docs/message-queues.rst
copy {airflow-core/src/airflow/_shared =>
providers/redis/src/airflow/providers/redis/queues}/__init__.py (100%)
copy
providers/{apache/kafka/src/airflow/providers/apache/kafka/queues/kafka.py =>
redis/src/airflow/providers/redis/queues/redis.py} (55%)
copy {airflow-core/src/airflow/_shared =>
providers/redis/tests/integration/redis/queues}/__init__.py (100%)
create mode 100644
providers/redis/tests/integration/redis/queues/test_redis_pubsub_message_queue.py
copy
providers/{common/messaging/tests/system/common/messaging/example_message_queue_trigger.py
=> redis/tests/system/redis/example_dag_message_queue_trigger.py} (78%)
copy {airflow-core/src/airflow/_shared =>
providers/redis/tests/unit/redis/queues}/__init__.py (100%)
copy providers/{apache/kafka/tests/unit/apache/kafka/queues/test_kafka.py =>
redis/tests/unit/redis/queues/test_redis.py} (63%)
