potiuk commented on a change in pull request #18439:
URL: https://github.com/apache/airflow/pull/18439#discussion_r764889409
##########
File path: airflow/utils/cli.py
##########
@@ -53,51 +54,57 @@ def _check_cli_args(args):
)
-def action_logging(f: T) -> T:
- """
- Decorates function to execute function at the same time submitting
action_logging
- but in CLI context. It will call action logger callbacks twice,
- one for pre-execution and the other one for post-execution.
-
- Action logger will be called with below keyword parameters:
- sub_command : name of sub-command
- start_datetime : start datetime instance by utc
- end_datetime : end datetime instance by utc
- full_command : full command line arguments
- user : current user
- log : airflow.models.log.Log ORM instance
- dag_id : dag id (optional)
- task_id : task_id (optional)
- execution_date : execution date (optional)
- error : exception instance if there's an exception
-
- :param f: function instance
- :return: wrapped function
- """
-
- @functools.wraps(f)
- def wrapper(*args, **kwargs):
+def action_cli(check_db=True):
Review comment:
Nice!
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
