Cleanup unused graphile tasks

This commit is contained in:
Eric Allam
2023-07-07 11:46:56 +01:00
parent 6527723a0e
commit 79eab3d62f
2 changed files with 0 additions and 53 deletions
@@ -116,10 +116,6 @@ export async function createOrganization(
userId,
});
await workerQueue.enqueue("organizationCreated", {
id: organization.id,
});
return { ...organization, projects: [project] };
}
-49
View File
@@ -21,7 +21,6 @@ import { DeliverHttpSourceRequestService } from "./sources/deliverHttpSourceRequ
import { PerformTaskOperationService } from "./tasks/performTaskOperation.server";
const workerCatalog = {
organizationCreated: z.object({ id: z.string() }),
indexEndpoint: z.object({
id: z.string(),
source: z.enum(["MANUAL", "API", "INTERNAL", "HOOK"]).optional(),
@@ -29,14 +28,6 @@ const workerCatalog = {
reason: z.string().optional(),
}),
scheduleEmail: DeliverEmailSchema,
githubAppInstallationDeleted: z.object({ id: z.string() }),
githubPush: z.object({
branch: z.string(),
commitSha: z.string(),
repository: z.string(),
}),
stopVM: z.object({ id: z.string() }),
startInitialProjectDeployment: z.object({ id: z.string() }),
startRun: z.object({ id: z.string() }),
performRunExecution: z.object({
id: z.string(),
@@ -204,46 +195,6 @@ function getWorkerQueue() {
await sendEmail(payload);
},
},
startInitialProjectDeployment: {
queueName: "internal-queue",
priority: 50,
maxAttempts: 3,
handler: async (payload, job) => {
// TODO: implement
},
},
stopVM: {
queueName: "internal-queue",
priority: 50,
maxAttempts: 3,
handler: async (payload, job) => {
// TODO: implement
},
},
organizationCreated: {
queueName: "internal-queue",
priority: 50,
maxAttempts: 3,
handler: async (payload, job) => {
// TODO: implement
},
},
githubPush: {
queueName: "internal-queue",
priority: 50,
maxAttempts: 3,
handler: async (payload, job) => {
// TODO: implement
},
},
githubAppInstallationDeleted: {
queueName: "internal-queue",
priority: 50,
maxAttempts: 3,
handler: async (payload, job) => {
// TODO: implement
},
},
indexEndpoint: {
queueName: "internal-queue",
handler: async (payload, job) => {