diff --git a/src/app/data-client.spec.ts b/src/app/data-client.spec.ts index 95e3c61ec..c3b9bd129 100644 --- a/src/app/data-client.spec.ts +++ b/src/app/data-client.spec.ts @@ -1430,6 +1430,7 @@ describe('DataPipelineClient tests', () => { const schedule = '0 0 * * *'; const dataSourceTypeStandard = TabularDataSourceType.STANDARD; const dataSourceTypeHotStorage = TabularDataSourceType.HOT_STORAGE; + const enableBackfill = true; describe('listDataPipelines tests', () => { const pipeline1 = new DataPipeline({ @@ -1538,6 +1539,7 @@ describe('DataPipelineClient tests', () => { name: pipelineName, mqlBinary: mqlQuery.map((value) => BSON.serialize(value)), schedule, + enableBackfill, dataSourceType: dataSourceTypeStandard, }); @@ -1546,6 +1548,7 @@ describe('DataPipelineClient tests', () => { pipelineName, mqlQuery, schedule, + enableBackfill, dataSourceTypeStandard ); expect(capReq).toStrictEqual(expectedRequest); @@ -1558,6 +1561,7 @@ describe('DataPipelineClient tests', () => { name: pipelineName, mqlBinary: mqlQuery.map((value) => BSON.serialize(value)), schedule, + enableBackfill, dataSourceType: dataSourceTypeStandard, }); @@ -1565,7 +1569,8 @@ describe('DataPipelineClient tests', () => { organizationId, pipelineName, mqlQuery, - schedule + schedule, + enableBackfill ); expect(capReq).toStrictEqual(expectedRequest); expect(response).toEqual(pipelineId); diff --git a/src/app/data-client.ts b/src/app/data-client.ts index 79544e93d..f05bb5c3a 100644 --- a/src/app/data-client.ts +++ b/src/app/data-client.ts @@ -1417,6 +1417,7 @@ export class DataClient { name: string, query: Uint8Array[] | Record[], schedule: string, + enableBackfill: boolean, dataSourceType?: TabularDataSourceType ): Promise { const mqlBinary: Uint8Array[] = @@ -1432,6 +1433,7 @@ export class DataClient { name, mqlBinary, schedule, + enableBackfill, dataSourceType: inputDataSourceType, }); return resp.id;