-
Notifications
You must be signed in to change notification settings - Fork 547
feat(datadog): Update to SDK v4 #11945
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
Conversation
|
Closes #11946 |
| } | ||
| for k, v := range customExceptions { | ||
| exceptions[k] = v | ||
| if err := c.scheduler.Sync(ctx, c.client.Duplicate(), tables, res, scheduler.WithSyncDeterministicCQID(options.DeterministicCQID)); err != nil { |
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.
just ret? (nit)
| if err := c.scheduler.Sync(ctx, c.client.Duplicate(), tables, res, scheduler.WithSyncDeterministicCQID(options.DeterministicCQID)); err != nil { | |
| return c.scheduler.Sync(ctx, c.client.Duplicate(), tables, res, scheduler.WithSyncDeterministicCQID(options.DeterministicCQID)) |
| type TestOptions struct{} | ||
|
|
||
| func filterInserts(msgs message.SyncMessages) message.SyncInserts { | ||
| inserts := []*message.SyncInsert{} |
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.
| inserts := []*message.SyncInsert{} | |
| var inserts := message.SyncInserts |
| if err := s.UnmarshalSpec(cfSpec); err != nil { | ||
| return nil, fmt.Errorf("failed to unmarshal datadog spec: %w", err) | ||
| } | ||
| func (c *Client) Duplicate() schema.ClientMeta { |
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.
is it used?
| } | ||
| for _, table := range tables { | ||
| addCqIDs(table) | ||
| titleTransformer(table) |
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.
@yevgenypats
using this will construct the csr for each table, instead of constructing caser once & reusing it for all transformations, though
🤖 I have created a release *beep* *boop* --- ## [3.1.0](plugins-source-datadog-v3.0.1...plugins-source-datadog-v3.1.0) (2023-07-07) ### Features * **datadog:** Update to SDK v4 ([#11945](#11945)) ([5377ac2](5377ac2)) ### Bug Fixes * **deps:** Update github.com/apache/arrow/go/v13 digest to 5a06b2e ([#11857](#11857)) ([43c2f5f](43c2f5f)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to 0656028 ([#11739](#11739)) ([7a6ad49](7a6ad49)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to 1e68c51 ([#11637](#11637)) ([46043bc](46043bc)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to 43638cb ([#11672](#11672)) ([3c60bbb](3c60bbb)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to 4d76231 ([#11532](#11532)) ([6f04233](6f04233)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to 8366a22 ([#11717](#11717)) ([8eeff5b](8eeff5b)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to 95d3199 ([#11708](#11708)) ([03f214f](03f214f)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to b0832be ([#11651](#11651)) ([71e8c29](71e8c29)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to d864719 ([#11611](#11611)) ([557a290](557a290)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to df3b664 ([#11882](#11882)) ([9635b22](9635b22)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to f060192 ([#11730](#11730)) ([c7019c2](c7019c2)) * **deps:** Update github.com/cloudquery/arrow/go/v13 digest to f0dffc6 ([#11689](#11689)) ([18ac0e9](18ac0e9)) * **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.1.0 ([#11665](#11665)) ([d8947c9](d8947c9)) * **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.2.0 ([#11720](#11720)) ([7ef521d](7ef521d)) * **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.2.1 ([#11722](#11722)) ([309be72](309be72)) * **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.3.3 ([#11726](#11726)) ([f0ca611](f0ca611)) * **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.3.4 ([#11753](#11753)) ([cd4fe1c](cd4fe1c)) * **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.5.0 ([#11850](#11850)) ([3255857](3255857)) * **deps:** Update module github.com/cloudquery/plugin-pb-go to v1.6.0 ([#11916](#11916)) ([421e752](421e752)) * **deps:** Update module github.com/cloudquery/plugin-sdk/v3 to v3.10.6 ([#11473](#11473)) ([7272133](7272133)) * **postgresql:** Rerun release please ([#12002](#12002)) ([9d12843](9d12843)) * Update SDK on sources ([#11983](#11983)) ([0da0bcf](0da0bcf)) --- This PR was generated with [Release Please](https://github.com/googleapis/release-please). See [documentation](https://github.com/googleapis/release-please#release-please).
No description provided.