如何在Airflow operator中打印独特的信息？

from airflow.models import BaseOperator
from airflow.utils.decorators import apply_defaults

class CustomOperator(BaseOperator):
    @apply_defaults
    def __init__(self, unique_info, *args, **kwargs):
        super(CustomOperator, self).__init__(*args, **kwargs)
        self.unique_info = unique_info

    def execute(self, context):
        print("Unique Info:", self.unique_info)
        # 或者使用日志库
        # logging.info("Unique Info: %s", self.unique_info)

# 在DAG中使用自定义Operator类
from airflow import DAG
from datetime import datetime

default_args = {
    'start_date': datetime(2022, 1, 1),
}

with DAG('custom_operator_example', default_args=default_args, schedule_interval='@daily') as dag:
    task1 = CustomOperator(
        task_id='print_unique_info',
        unique_info='This is a unique message.',
    )