diff --git a/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.html b/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.html
index 8921047..5e57c97 100644
--- a/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.html
+++ b/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.html
@@ -1156,6 +1156,9 @@
+
diff --git a/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.ts b/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.ts
index c2f3e33..88fb24d 100644
--- a/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.ts
+++ b/frontend/angular-clarity-master/src/app/modules/main/builder/dashboardnew/Data_lake/Data_lake.component.ts
@@ -1603,7 +1603,7 @@ export class Data_lakeComponent implements OnInit {
name: this.selectedSchedulerItem.name,
status: 'RUNNING',
description: `Scheduled job for ${this.selectedSchedulerItem.name}`,
- jobType: 'SYNC',
+ jobType: 'DATALAKE',
lakeid: this.selectedSchedulerItem.id
};
@@ -1676,6 +1676,34 @@ export class Data_lakeComponent implements OnInit {
);
}
+ // Method to restart a stopped job
+ restartJob() {
+ if (!this.schedulerJob || !this.schedulerJob.id) {
+ this.toastr.error('No job selected');
+ return;
+ }
+
+ // To restart a job, we need to create a new job with the same parameters
+ const jobData = {
+ name: this.schedulerJob.name,
+ status: 'RUNNING',
+ description: this.schedulerJob.description,
+ jobType: this.schedulerJob.jobType,
+ lakeid: this.schedulerJob.lakeid
+ };
+
+ this.schedulerService.createJob(jobData).subscribe(
+ (job: any) => {
+ this.schedulerJob = job;
+ this.toastr.success('Job restarted successfully');
+ },
+ (error) => {
+ console.error('Error restarting job:', error);
+ this.toastr.error('Failed to restart job');
+ }
+ );
+ }
+
// Method to close scheduler modal
closeSchedulerModal() {
this.showSchedulerModal = false;