-
Notifications
You must be signed in to change notification settings - Fork 361
DRAFT: AI WRITTEN INTEGRATION bullmq #7123
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
base: conti/all-tooling-changes
Are you sure you want to change the base?
Conversation
Overall package sizeSelf size: 4.35 MB Dependency sizes| name | version | self size | total size | |------|---------|-----------|------------| | import-in-the-middle | 1.15.0 | 127.66 kB | 856.24 kB | | dc-polyfill | 0.1.10 | 26.73 kB | 26.73 kB |🤖 This report was automatically generated by heaviest-objects-in-the-universe |
Codecov Report❌ Patch coverage is Additional details and impacted files@@ Coverage Diff @@
## conti/all-tooling-changes #7123 +/- ##
=============================================================
- Coverage 84.77% 84.74% -0.04%
=============================================================
Files 521 521
Lines 22162 22162
=============================================================
- Hits 18788 18781 -7
- Misses 3374 3381 +7 ☔ View full report in Codecov by Sentry. 🚀 New features to boost your workflow:
|
| "private": true, | ||
| "dependencies": { | ||
| "@ai-sdk/openai": "2.0.65", | ||
| "@anthropic-ai/sdk": "0.68.0", |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
workflow sorts this file, so that explains the sorting change. really only 1 line for bullmq was added
| describe('Queue.add() - bullmq.add', () => { | ||
| it('should generate span with correct tags (happy path)', async () => { | ||
| const traceAssertion = agent.assertSomeTraces((traces) => { | ||
| const spans = traces[0] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Would prefer using the assertFirstTrace function that supports including the span object shape instead of separate assertion lines. assertFirstTrace name may be confusing the agent.
BenchmarksBenchmark execution time: 2025-12-22 18:38:08 Comparing candidate commit c472a1d in PR branch Found 0 performance improvements and 0 performance regressions! Performance is the same for 288 metrics, 32 unstable metrics. |
| - uses: actions/checkout@08c6903cd8c0fde910a37f88322edcfb5dd907a8 # v5.0.0 | ||
| - uses: ./.github/actions/plugins/test | ||
| with: | ||
| dd_api_key: ${{{{ secrets.DD_API_KEY }}}} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
damn son, heard you like curly braces
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
This happened in the NATS PR as well
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
easy fix! And simon's comment made me "lol"
|
|
||
| module.exports = [ | ||
| ...require('./langchain') | ||
| ...require('./langchain'), |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
need to add this change to node file generators.
| const producerSpan = spans.find(span => span.name === 'bullmq.add') | ||
| if (!producerSpan) { | ||
| throw new Error('Producer span bullmq.add not found') | ||
| } |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Something like this would be more idiomatic:
| const producerSpan = spans.find(span => span.name === 'bullmq.add') | |
| if (!producerSpan) { | |
| throw new Error('Producer span bullmq.add not found') | |
| } | |
| const producerSpan = spans.find(span => span.name === 'bullmq.add') | |
| expect(producerSpan, 'Producer span bullmq.add not found').to.be.ok |
| redis: | ||
| image: redis:4.0-alpine | ||
| image: redis:7.0-alpine | ||
| ports: | ||
| - "127.0.0.1:6379:6379" |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
I think this is okay... Redis is good about backwards compatibility. So even though we're testing old library versions they should behave the same with a newer Redis.
Another approach is to add a separate image just for bullmq stuff:
redis:
image: redis:7.0-alpine
ports:
- "127.0.0.1:16379:6379"^ that would avoid port conflicts and would also need the test code to use port 16379 instead of the default 6379. But I'll defer to others.
|
Shouldn't there be a new |
@tlhunter What is this? I'm not aware of what this is |
|
I was saying we need a new test to appear in the list of github actions that have executed as a result of this pull request. Such a test was not present when I reviewed previously but is now working.
|
| const edgeTags = isProducer | ||
| ? ['direction:out', `topic:${queueName}`, 'type:bullmq'] | ||
| : ['direction:in', `topic:${queueName}`, 'type:bullmq'] |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
| const edgeTags = isProducer | |
| ? ['direction:out', `topic:${queueName}`, 'type:bullmq'] | |
| : ['direction:in', `topic:${queueName}`, 'type:bullmq'] | |
| const edgeTags = [isProducer ? 'direction:out' : 'direction:in', `topic:${queueName}`, 'type:bullmq'] |

What does this PR do?
AI GENERATED integration for bullmq
Motivation
Plugin Checklist
Additional Notes