Clippy fixes

Author: Sushisource

core/src/worker/activities.rs

@@ -352,7 +352,7 @@ impl WorkerActivityTasks {
                     aer::Status::Failed(ar::Failure { failure }) => {
                         act_metrics.act_execution_failed();
                         client
-                            .fail_activity_task(task_token.clone(), failure.map(Into::into))
+                            .fail_activity_task(task_token.clone(), failure)
                             .await
                             .err()
                     }
@@ -387,7 +387,7 @@ impl WorkerActivityTasks {
                                 None
                             };
                             client
-                                .cancel_activity_task(task_token.clone(), details.map(Into::into))
+                                .cancel_activity_task(task_token.clone(), details)
                                 .await
                                 .err()
                         }

core/src/worker/workflow/machines/activity_state_machine.rs

@@ -750,7 +750,7 @@ fn new_cancel_failure(dat: &SharedState, attrs: ActivityTaskCanceledEventAttribu
         message: "Activity cancelled".to_string(),
         cause: Some(Box::from(Failure {
             failure_info: Some(FailureInfo::CanceledFailureInfo(CanceledFailureInfo {
-                details: attrs.details.map(Into::into),
+                details: attrs.details,
             })),
             ..Default::default()
         })),

core/src/worker/workflow/machines/workflow_machines.rs

@@ -1029,7 +1029,7 @@ impl WorkflowMachines {
     }
 
     fn set_current_time(&mut self, time: SystemTime) -> SystemTime {
-        if self.current_wf_time.map_or(true, |t| t < time) {
+        if self.current_wf_time.is_none_or(|t| t < time) {
             self.current_wf_time = Some(time);
         }
         self.current_wf_time

core/src/worker/workflow/mod.rs

@@ -429,7 +429,7 @@ impl Workflows {
                     warn!(run_id=%run_id, failure=?failure, "Failing workflow task");
                     self.handle_wft_reporting_errs(&run_id, || async {
                         self.client
-                            .fail_workflow_task(tt, cause, failure.failure.map(Into::into))
+                            .fail_workflow_task(tt, cause, failure.failure)
                             .await
                     })
                     .await;

sdk-core-protos/src/lib.rs

@@ -1263,7 +1263,7 @@ pub mod coresdk {
                         schedule_to_close_timeout: r.schedule_to_close_timeout,
                         start_to_close_timeout: r.start_to_close_timeout,
                         heartbeat_timeout: r.heartbeat_timeout,
-                        retry_policy: r.retry_policy.map(Into::into),
+                        retry_policy: r.retry_policy,
                         is_local: false,
                     },
                 )),
@@ -1424,7 +1424,7 @@ pub mod coresdk {
         fn from_payloads(p: Option<Payloads>) -> Self {
             match p {
                 None => std::iter::empty().collect(),
-                Some(p) => p.payloads.into_iter().map(Into::into).collect(),
+                Some(p) => p.payloads.into_iter().collect(),
             }
         }
     }
@@ -1442,7 +1442,7 @@ pub mod coresdk {
                 None
             } else {
                 Some(Payloads {
-                    payloads: iterd.map(Into::into).collect(),
+                    payloads: iterd.collect(),
                 })
             }
         }