Skip to content

Commit 3acc69d

Browse files
authored
DATA-4220 Add EnableBackfill boolean to CreateDataPipeline (#586)
1 parent 4e3cb80 commit 3acc69d

File tree

2 files changed

+8
-1
lines changed

2 files changed

+8
-1
lines changed

src/app/data-client.spec.ts

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1463,6 +1463,7 @@ describe('DataPipelineClient tests', () => {
14631463
const schedule = '0 0 * * *';
14641464
const dataSourceTypeStandard = TabularDataSourceType.STANDARD;
14651465
const dataSourceTypeHotStorage = TabularDataSourceType.HOT_STORAGE;
1466+
const enableBackfill = true;
14661467

14671468
describe('listDataPipelines tests', () => {
14681469
const pipeline1 = new DataPipeline({
@@ -1571,6 +1572,7 @@ describe('DataPipelineClient tests', () => {
15711572
name: pipelineName,
15721573
mqlBinary: mqlQuery.map((value) => BSON.serialize(value)),
15731574
schedule,
1575+
enableBackfill,
15741576
dataSourceType: dataSourceTypeStandard,
15751577
});
15761578

@@ -1579,6 +1581,7 @@ describe('DataPipelineClient tests', () => {
15791581
pipelineName,
15801582
mqlQuery,
15811583
schedule,
1584+
enableBackfill,
15821585
dataSourceTypeStandard
15831586
);
15841587
expect(capReq).toStrictEqual(expectedRequest);
@@ -1591,14 +1594,16 @@ describe('DataPipelineClient tests', () => {
15911594
name: pipelineName,
15921595
mqlBinary: mqlQuery.map((value) => BSON.serialize(value)),
15931596
schedule,
1597+
enableBackfill,
15941598
dataSourceType: dataSourceTypeStandard,
15951599
});
15961600

15971601
const response = await subject().createDataPipeline(
15981602
organizationId,
15991603
pipelineName,
16001604
mqlQuery,
1601-
schedule
1605+
schedule,
1606+
enableBackfill
16021607
);
16031608
expect(capReq).toStrictEqual(expectedRequest);
16041609
expect(response).toEqual(pipelineId);

src/app/data-client.ts

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1431,6 +1431,7 @@ export class DataClient {
14311431
name: string,
14321432
query: Uint8Array[] | Record<string, Date | JsonValue>[],
14331433
schedule: string,
1434+
enableBackfill: boolean,
14341435
dataSourceType?: TabularDataSourceType
14351436
): Promise<string> {
14361437
const mqlBinary: Uint8Array[] =
@@ -1446,6 +1447,7 @@ export class DataClient {
14461447
name,
14471448
mqlBinary,
14481449
schedule,
1450+
enableBackfill,
14491451
dataSourceType: inputDataSourceType,
14501452
});
14511453
return resp.id;

0 commit comments

Comments
 (0)