diff options
| author | Paul Buetow <paul@buetow.org> | 2025-06-25 12:56:06 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2025-06-25 12:56:06 +0300 |
| commit | 07a1147a7291938d2433efda5ecb2855cd1e3f18 (patch) | |
| tree | 12e95bc9406062dbba5d75619f673ff980352c18 /integrationtests/testhelpers.go | |
| parent | ecd2d3c6e521d78eb005001ceaf0a97e62571de8 (diff) | |
Add multi-server MapReduce integration test
- Implement TestDMapMultiServer to test distributed MapReduce across multiple servers
- Add support for environment variables in test server configuration
- Fix TestDMap3 query to match expected output (was using non-existent $queriesPerSecond field)
- Update test helpers to support environment variables for servers
- All integration tests now pass successfully
The multi-server test demonstrates:
- MapReduce queries work correctly across multiple DTail servers
- Data aggregation from all servers functions properly
- GROUP BY operations work in distributed environment
🤖 Generated with [Claude Code](https://claude.ai/code)
Co-Authored-By: Claude <noreply@anthropic.com>
Diffstat (limited to 'integrationtests/testhelpers.go')
| -rw-r--r-- | integrationtests/testhelpers.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/integrationtests/testhelpers.go b/integrationtests/testhelpers.go index 2bbf077..abcf0f4 100644 --- a/integrationtests/testhelpers.go +++ b/integrationtests/testhelpers.go @@ -25,6 +25,7 @@ type ServerConfig struct { BindAddress string LogLevel string ExtraArgs []string + Env map[string]string } // DefaultServerConfig returns a default server configuration @@ -52,7 +53,7 @@ func startTestServer(t *testing.T, ctx context.Context, cfg *ServerConfig) error } args = append(args, cfg.ExtraArgs...) - _, _, _, err := startCommand(ctx, t, "", "../dserver", args...) + _, _, _, err := startCommandWithEnv(ctx, t, "", "../dserver", cfg.Env, args...) if err != nil { return err } |