Skip to content

Commit

Permalink
removed unused code
Browse files Browse the repository at this point in the history
  • Loading branch information
Dmitriy Borzenko committed Dec 17, 2024
1 parent d49570e commit 9323ec5
Show file tree
Hide file tree
Showing 3 changed files with 0 additions and 145 deletions.
75 changes: 0 additions & 75 deletions src/app/api/dataset-flow.api.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -39,16 +39,13 @@ import { noCacheFetchPolicy } from "../common/data.helpers";
@Injectable({ providedIn: "root" })
export class DatasetFlowApi {
private getDatasetFlowConfigsGQL = inject(GetDatasetFlowConfigsGQL);
// private datasetFlowScheduleGQL = inject(DatasetFlowScheduleGQL);
// private datasetFlowBatchingGQL = inject(DatasetFlowBatchingGQL);
private getDatasetListFlowsGQL = inject(GetDatasetListFlowsGQL);
private datasetPauseFlowsGQL = inject(DatasetPauseFlowsGQL);
private datasetResumeFlowsGQL = inject(DatasetResumeFlowsGQL);
private datasetAllFlowsPausedGQL = inject(DatasetAllFlowsPausedGQL);
private datasetTriggerFlowGQL = inject(DatasetTriggerFlowGQL);
private datasetFlowByIdGQL = inject(GetFlowByIdGQL);
private cancelScheduledTasksGQL = inject(CancelScheduledTasksGQL);
// private datasetFlowCompactionGQL = inject(DatasetFlowCompactionGQL);
private datasetFlowsInitiatorsGQL = inject(DatasetFlowsInitiatorsGQL);
private setDatasetFlowConfigGQL = inject(SetDatasetFlowConfigGQL);
private setDatasetFlowTriggersGQL = inject(SetDatasetFlowTriggersGQL);
Expand Down Expand Up @@ -147,54 +144,6 @@ export class DatasetFlowApi {
);
}

// public setDatasetFlowSchedule(params: {
// accountId: string;
// datasetId: string;
// datasetFlowType: DatasetFlowType;
// paused: boolean;
// ingest: IngestConditionInput;
// }): Observable<DatasetFlowScheduleMutation> {
// return this.datasetFlowScheduleGQL
// .mutate({
// ...params,
// })
// .pipe(
// first(),
// map((result: MutationResult<DatasetFlowScheduleMutation>) => {
// /* istanbul ignore else */
// if (result.data) {
// return result.data;
// } else {
// throw new DatasetOperationError(result.errors ?? []);
// }
// }),
// );
// }

// public setDatasetFlowBatching(params: {
// accountId: string;
// datasetId: string;
// datasetFlowType: DatasetFlowType;
// paused: boolean;
// transform: TransformConditionInput;
// }): Observable<DatasetFlowBatchingMutation> {
// return this.datasetFlowBatchingGQL
// .mutate({
// ...params,
// })
// .pipe(
// first(),
// map((result: MutationResult<DatasetFlowBatchingMutation>) => {
// /* istanbul ignore else */
// if (result.data) {
// return result.data;
// } else {
// throw new DatasetOperationError(result.errors ?? []);
// }
// }),
// );
// }

public getDatasetListFlows(params: {
datasetId: string;
page: number;
Expand Down Expand Up @@ -309,30 +258,6 @@ export class DatasetFlowApi {
);
}

// public setDatasetFlowCompaction(params: {
// datasetId: string;
// datasetFlowType: DatasetFlowType;
// compactionArgs: CompactionConditionInput;
// }): Observable<DatasetFlowCompactionMutation> {
// return this.datasetFlowCompactionGQL
// .mutate({
// datasetId: params.datasetId,
// datasetFlowType: params.datasetFlowType,
// compactionArgs: params.compactionArgs,
// })
// .pipe(
// first(),
// map((result: MutationResult<DatasetFlowCompactionMutation>) => {
// /* istanbul ignore else */
// if (result.data) {
// return result.data;
// } else {
// throw new DatasetOperationError(result.errors ?? []);
// }
// }),
// );
// }

public getDatasetFlowsInitiators(datasetId: string): Observable<DatasetFlowsInitiatorsQuery> {
return this.datasetFlowsInitiatorsGQL.watch({ datasetId }, noCacheFetchPolicy).valueChanges.pipe(
map((result: ApolloQueryResult<DatasetFlowsInitiatorsQuery>) => {
Expand Down
46 changes: 0 additions & 46 deletions src/app/api/gql/compacting-dataset/dataset-flow-compacting.graphql
View file

This file was deleted.

24 changes: 0 additions & 24 deletions src/app/common/components/flows-table/flows-table.component.ts
View file
Original file line number Diff line number Diff line change
Expand Up @@ -224,30 +224,6 @@ export class FlowsTableComponent extends BaseComponent implements OnInit, OnChan
}
}

// private setScheduleOptions(node: FlowSummaryDataFragment): IngestConditionInput {
// /* istanbul ignore else */
// if (node.configSnapshot?.__typename === "FlowConfigurationIngest") {
// switch (node.configSnapshot.schedule.__typename) {
// case "TimeDelta":
// return {
// fetchUncacheable: true,
// };
// case "Cron5ComponentExpression":
// return {
// schedule: {
// cron5ComponentExpression: node.configSnapshot.schedule.cron5ComponentExpression,
// },
// fetchUncacheable: true,
// };
// /* istanbul ignore next */
// default:
// throw new Error("Unknown configuration schedule type");
// }
// } else {
// throw new Error("The type for the configuration is not FlowConfigurationIngest");
// }
// }

private initializeFilters(): void {
this.dropdownDatasetList = this.involvedDatasets.slice(0, this.FILTERED_ITEMS_COUNT);
this.selectedDatasetItems = this.searchByDataset;
Expand Down

0 comments on commit 9323ec5

Please sign in to comment.