Kacper K
11/25/2024, 12:14 PMNate
11/25/2024, 2:43 PMPREFECT_LOGGING_EXTRA_LOGGERS=pyspark-kafka
? that will work if pyspark-kafka
defines a custom python logger and thats what you want to captureKacper K
11/27/2024, 2:12 PMKacper K
11/27/2024, 2:12 PMNate
11/27/2024, 2:28 PM» PREFECT_LOGGING_EXTRA_LOGGERS=foo,bar ipython
In [1]: from prefect.settings import PREFECT_LOGGING_EXTRA_LOGGERS
In [2]: PREFECT_LOGGING_EXTRA_LOGGERS.value()
Out[2]: ['bar', 'foo']
Kacper K
11/27/2024, 2:32 PMNate
11/27/2024, 2:34 PMNate
11/27/2024, 2:35 PMKacper K
11/27/2024, 2:38 PMKacper K
11/27/2024, 2:39 PMlogger.py:53: UserWarning: Logger 'ds-data-logger' attempted to send logs to the API without a flow run id. The API log handler can only send logs within flow run contexts unless the flow run id is manually provided.