Skip to content

Commit fc859cc

Browse files
committed
Merge branch 'main' of github.com:CrowdDotDev/crowd.dev into main
2 parents 115bb8a + 2511cb8 commit fc859cc

10 files changed

Lines changed: 795 additions & 133 deletions

File tree

backend/src/database/migrations/U1763654470__optimize_organization_api.sql

Whitespace-only changes.
Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,9 @@
1+
CREATE INDEX CONCURRENTLY IF NOT EXISTS idx_osa_segment_coalesce_activity_org
2+
ON public."organizationSegmentsAgg" (
3+
"segmentId",
4+
(coalesce("activityCount", 0)::integer) DESC,
5+
"organizationId"
6+
);
7+
8+
CREATE INDEX CONCURRENTLY IF NOT EXISTS idx_org_displayname_trgm
9+
ON organizations USING gin ("displayName" gin_trgm_ops);

services/apps/nango_worker/src/workflows/syncGithubIntegration.ts

Lines changed: 8 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,10 +1,10 @@
1-
import { proxyActivities } from '@temporalio/workflow'
1+
import { proxyActivities, sleep } from '@temporalio/workflow'
22

33
import * as activities from '../activities/nangoActivities'
44
import { ISyncGithubIntegrationArguments } from '../types'
55

66
const activity = proxyActivities<typeof activities>({
7-
startToCloseTimeout: '10 minutes',
7+
startToCloseTimeout: '1 hour',
88
})
99

1010
export async function syncGithubIntegration(args: ISyncGithubIntegrationArguments): Promise<void> {
@@ -59,6 +59,12 @@ export async function syncGithubIntegration(args: ISyncGithubIntegrationArgument
5959
await activity.startNangoSync(result.providerConfigKey, connectionId)
6060

6161
created++
62+
63+
if (created < limit) {
64+
// random delay between 1-5 minutes to not overload nango server
65+
const jitterMs = 60000 + Math.random() * 240000
66+
await sleep(jitterMs)
67+
}
6268
}
6369
}
6470
}

0 commit comments

Comments
 (0)