Skip to content

Worker logging doesn't work #634

@lpogo

Description

@lpogo

Checklist

  • I have included information about relevant versions
  • I have verified that the issue persists when using the master branch of Faust.

Steps to reproduce

After upgrade to faust-streaming > 0.8.10 (PR: #368) I am not able to force faust to logging any info from Worker. When app sis starting, only +ƒaµS† v0.8.11+ table info is printed and any warnings before.
Before version 0.8.11 it was working like that.
When I am using logging_config in faust.App (0.8.10) my logging configuration is fine. Since 0.8.11 it is not.

When you change lines back in faust/worker.py (reverse PR changes), then everything is working fine.
The same, when override_logging is changed to False in source code of mode.Worker (parent of faust.Worker)

Any idea whats wrong or how to handle logging?

Expected behavior

Faust print info like:

[^Worker]: Starting...
[^-App]: Starting...
[^-App]: Started.
Executing _on_partitions_assigned
[^Worker]: Ready
[^Worker]: Started.

based on defined logging configuration as well as info about processed events.

Actual behavior

Only +ƒaµS† v0.8.11+ table info is printed to log and warinign before. After that nothing is logged, even errors related to communication issue.

Full traceback

n/a

Versions

  • Python version: 3.10
  • Faust versio: starting from 0.8.11
  • Operating system: Windows/Linux container
  • aiokafka: 0.10.0
  • Django 4.2.11

Metadata

Metadata

Assignees

No one assigned

    Labels

    No labels
    No labels

    Type

    No type

    Projects

    No projects

    Milestone

    No milestone

    Relationships

    None yet

    Development

    No branches or pull requests

    Issue actions