uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1169377593
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1168419800
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1166043127
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1166046760
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,32 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1166046035
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1166044816
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,32 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1166043127
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1166042132
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,32 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1165356187
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1164532124
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1164531196
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1164530740
##
airflow/cli/commands/celery_command.py:
##
@@ -96,6 +100,27 @@ def _serve_logs(skip_serve_logs: bool = False):
sub_proc.terminate()
uranusjr commented on code in PR #30485:
URL: https://github.com/apache/airflow/pull/30485#discussion_r1159353154
##
airflow/cli/commands/celery_command.py:
##
@@ -18,13 +18,16 @@
"""Celery command."""
from __future__ import annotations
+import logging
from contextlib
13 matches
Mail list logo