Kludex commented on issue #33176:
URL: https://github.com/apache/beam/issues/33176#issuecomment-2516887972
I got something nice running. Although not there yet...
My understanding about this package is growing a bit more... 😅
```py
def patch_beam_pipeline():
Pipeline.apply = logfire.instrument("{transform}",
extract_args=True)(Pipeline.apply)
Pipeline.run = logfire.instrument()(Pipeline.run)
patch_beam_pipeline()
```
With the lines above, I'm able to patch `run` and `apply` - I thought the
transformers would run in the `apply`, so that's what I was trying to patch,
but it looks like the important bit is the `run`. Although I see how nice
having both instrumented gets:
<img width="1480" alt="Screenshot 2024-12-04 at 11 26 23"
src="https://github.com/user-attachments/assets/d5e8b662-d352-49ca-bf0d-df9e515b224a";>
Now I need to find where the `PTransformer`s logic is executed.
--
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]
