Writing to Airflow Logs

You might use airflow logger

import logging


logger = logging.getLogger("airflow.task")
logger.error("Your custom error")

You can import the logging module into your code and write to logs that way

import logging

logging.info('Hello')

Here are some more options

import logging    

logging.debug('This is a debug message')
logging.info('This is an info message')
logging.warning('This is a warning message')
logging.error('This is an error message')
logging.critical('This is a critical message')