Mirrors/plane
1
0
Fork 0
mirror of https://github.com/makeplane/plane.git synced 2026-07-13 22:09:12 +02:00
Code Issues Packages Projects Releases Wiki Activity

[SILO-386] Fix modules not getting attached to WI #3649

Browse Source
This commit is contained in:
Saurabh Kumar
2025-07-11 19:23:46 +05:30
committed by GitHub
parent 48d24f2aaa
commit 18d0f39697
2 changed files with 7 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
apps/silo/src/etl/migrator/migrator.ts
View File

@@ -18,7 +18,6 @@ import {
IMPORT_JOB_PLANE_ISSUE_PROPERTIES_CACHE_KEY,
IMPORT_JOB_PLANE_ISSUE_PROPERTY_OPTIONS_CACHE_KEY,
IMPORT_JOB_PLANE_ISSUE_TYPES_CACHE_KEY,
IMPORT_JOB_PLANE_MODULES_CACHE_KEY,
IMPORT_JOB_FIRST_PAGE_PUSHED_CACHE_KEY,
} from "@/helpers/cache-keys";
import { IMPORT_JOB_KEYS_TTL_IN_SECONDS } from "@/helpers/constants";
@@ -57,7 +56,6 @@ export async function migrateToPlane(job: TImportJob, data: PlaneEntities[], met
// Create the data required for the workspace
let planeLabels: ExIssueLabel[] = [];
let planeUsers: PlaneUser[] = [];
let planeModules: { id: string; issues: string[] }[] = [];
let planeIssueTypes: ExIssueType[] = [];
let planeIssueProperties: ExIssueProperty[] = [];
let planeIssuePropertiesOptions: ExIssuePropertyOption[] = [];
@@ -129,7 +127,6 @@ export async function migrateToPlane(job: TImportJob, data: PlaneEntities[], met
const issueTypesCacheKey = IMPORT_JOB_PLANE_ISSUE_TYPES_CACHE_KEY(job.id);
const issuePropertiesCacheKey = IMPORT_JOB_PLANE_ISSUE_PROPERTIES_CACHE_KEY(job.id);
const issuePropertyOptionsCacheKey = IMPORT_JOB_PLANE_ISSUE_PROPERTY_OPTIONS_CACHE_KEY(job.id);
const modulesCacheKey = IMPORT_JOB_PLANE_MODULES_CACHE_KEY(job.id);
const store = Store.getInstance();
@@ -148,11 +145,6 @@ export async function migrateToPlane(job: TImportJob, data: PlaneEntities[], met
logger.info(`Found cached issue property options`, { jobId: job.id });
planeIssuePropertiesOptions = JSON.parse(cachedIssuePropertyOptions);
}
const cachedModules = await store.get(modulesCacheKey);
if (cachedModules) {
logger.info(`Found cached modules`, { jobId: job.id });
planeModules = JSON.parse(cachedModules);
}
const triggerIssueTypeStep =
isIssueTypeFeatureEnabled && (!cachedIssueTypes || !cachedIssueProperties || !cachedIssuePropertyOptions);
@@ -385,16 +377,13 @@ export async function migrateToPlane(job: TImportJob, data: PlaneEntities[], met
);
// ------------------- Module Creation --------------------
if (!cachedModules) {
planeModules = await createAllModules(
job.id,
modules as ExModule[],
planeClient,
job.workspace_slug,
job.project_id
);
await store.set(modulesCacheKey, JSON.stringify(planeModules), IMPORT_JOB_KEYS_TTL_IN_SECONDS);
}
const planeModules = await createAllModules(
job.id,
modules as ExModule[],
planeClient,
job.workspace_slug,
job.project_id
);
// ------------------- Issue Type Cache Storage -------------------- if the issue type step is triggered
if (triggerIssueTypeStep) {

2
apps/silo/src/helpers/cache-keys.ts
View File

@@ -24,8 +24,6 @@ export const IMPORT_JOB_PLANE_ISSUE_PROPERTIES_CACHE_KEY = (jobId: string) =>
export const IMPORT_JOB_PLANE_ISSUE_PROPERTY_OPTIONS_CACHE_KEY = (jobId: string) =>
`silo:import_job_plane_issue_property_options_${jobId}`;
export const IMPORT_JOB_PLANE_MODULES_CACHE_KEY = (jobId: string) => `silo:import_job_plane_modules_${jobId}`;
export const IMPORT_JOB_PLANE_MEMBERS_CACHE_KEY = (jobId: string) => `silo:import_job_plane_members_${jobId}`;
export const IMPORT_JOB_FIRST_PAGE_PUSHED_CACHE_KEY = (jobId: string) => `silo:import_job_first_page_pushed_${jobId}`;