From 540ddfd013b02b65278f47d3fe07f2947ec9926b Mon Sep 17 00:00:00 2001 From: Sergei Zaychenko Date: Sun, 4 Feb 2024 00:56:20 -0800 Subject: [PATCH] Simlified structure patterns for irrelevant fields --- .../tests/test_protocol_dataset_helpers.rs | 44 +++++++++---------- src/app/cli/src/commands/ingest_command.rs | 6 +-- src/app/cli/src/commands/log_command.rs | 17 ++----- src/app/cli/src/commands/pull_command.rs | 12 ++--- src/app/cli/src/commands/push_command.rs | 2 +- .../tests/tests/test_system_info_command.rs | 7 +-- src/domain/core/src/services/pull_service.rs | 8 +--- .../src/entities/flow/flow_state.rs | 32 ++++---------- .../flow_configuration_state.rs | 9 +--- .../task-system/src/entities/task_state.rs | 27 ++++++------ .../src/ingest/polling_ingest_service_impl.rs | 5 +-- .../core/tests/tests/ingest/test_writer.rs | 8 ++-- .../tests/tests/test_pull_service_impl.rs | 10 ++--- .../tests/tests/test_sync_service_impl.rs | 2 +- .../tests/test_verification_service_impl.rs | 6 +-- .../test_flow_configuration_service_inmem.rs | 8 ++-- .../src/task_executor_inmem.rs | 2 +- .../tests/tests/test_task_scheduler_inmem.rs | 3 +- 18 files changed, 74 insertions(+), 134 deletions(-) diff --git a/src/adapter/http/tests/tests/test_protocol_dataset_helpers.rs b/src/adapter/http/tests/tests/test_protocol_dataset_helpers.rs index 750831f18..a9031d009 100644 --- a/src/adapter/http/tests/tests/test_protocol_dataset_helpers.rs +++ b/src/adapter/http/tests/tests/test_protocol_dataset_helpers.rs @@ -107,13 +107,13 @@ async fn test_object_url_local_fs() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, pull_strategy: messages::ObjectPullStrategy::HttpDownload, download_from: messages::TransferUrl { url: download_from_url, headers: download_from_headers, - expires_at: _ + .. } } if object_type == messages::ObjectType::DataSlice && @@ -133,13 +133,13 @@ async fn test_object_url_local_fs() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, pull_strategy: messages::ObjectPullStrategy::HttpDownload, download_from: messages::TransferUrl { url: download_from_url, headers: download_from_headers, - expires_at: _ + .. } } if object_type == messages::ObjectType::Checkpoint && @@ -158,8 +158,7 @@ async fn test_object_url_local_fs() { messages::PushObjectTransferStrategy { object_file: messages::ObjectFileReference { object_type: messages::ObjectType::DataSlice, - physical_hash: _, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::SkipUpload, upload_to: None @@ -171,8 +170,7 @@ async fn test_object_url_local_fs() { messages::PushObjectTransferStrategy { object_file: messages::ObjectFileReference { object_type: messages::ObjectType::Checkpoint, - physical_hash: _, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::SkipUpload, upload_to: None @@ -185,13 +183,13 @@ async fn test_object_url_local_fs() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::HttpUpload, upload_to: Some(messages::TransferUrl { url: upload_to_url, headers: upload_to_headers, - expires_at: _ + .. }) } if object_type == messages::ObjectType::DataSlice && @@ -210,13 +208,13 @@ async fn test_object_url_local_fs() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::HttpUpload, upload_to: Some(messages::TransferUrl { url: upload_to_url, headers: upload_to_headers, - expires_at: _ + .. }) } if object_type == messages::ObjectType::Checkpoint && @@ -312,13 +310,13 @@ async fn test_pull_object_url_s3() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, pull_strategy: messages::ObjectPullStrategy::HttpDownload, download_from: messages::TransferUrl { url: download_from_url, headers: download_from_headers, - expires_at: _ + .. } } if object_type == messages::ObjectType::DataSlice && @@ -338,13 +336,13 @@ async fn test_pull_object_url_s3() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, pull_strategy: messages::ObjectPullStrategy::HttpDownload, download_from: messages::TransferUrl { url: download_from_url, headers: download_from_headers, - expires_at: _ + .. } } if object_type == messages::ObjectType::Checkpoint && @@ -364,8 +362,7 @@ async fn test_pull_object_url_s3() { messages::PushObjectTransferStrategy { object_file: messages::ObjectFileReference { object_type: messages::ObjectType::DataSlice, - physical_hash: _, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::SkipUpload, upload_to: None @@ -377,8 +374,7 @@ async fn test_pull_object_url_s3() { messages::PushObjectTransferStrategy { object_file: messages::ObjectFileReference { object_type: messages::ObjectType::Checkpoint, - physical_hash: _, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::SkipUpload, upload_to: None @@ -391,13 +387,13 @@ async fn test_pull_object_url_s3() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::HttpUpload, upload_to: Some(messages::TransferUrl { url: upload_to_url, headers: upload_to_headers, - expires_at: _ + .. }) } if object_type == messages::ObjectType::DataSlice && @@ -416,13 +412,13 @@ async fn test_pull_object_url_s3() { object_file: messages::ObjectFileReference { object_type, physical_hash, - size: _, + .. }, push_strategy: messages::ObjectPushStrategy::HttpUpload, upload_to: Some(messages::TransferUrl { url: upload_to_url, headers: upload_to_headers, - expires_at: _ + .. }) } if object_type == messages::ObjectType::Checkpoint && diff --git a/src/app/cli/src/commands/ingest_command.rs b/src/app/cli/src/commands/ingest_command.rs index a9b263f08..0d096441d 100644 --- a/src/app/cli/src/commands/ingest_command.rs +++ b/src/app/cli/src/commands/ingest_command.rs @@ -292,11 +292,7 @@ impl PushIngestListener for PushIngestProgress { console::style("Dataset is up-to-date".to_owned()).yellow(), )); } - PushIngestResult::Updated { - old_head: _, - ref new_head, - num_blocks: _, - } => { + PushIngestResult::Updated { ref new_head, .. } => { state .curr_progress .finish_with_message(Self::spinner_message( diff --git a/src/app/cli/src/commands/log_command.rs b/src/app/cli/src/commands/log_command.rs index 770c21580..c656e25d4 100644 --- a/src/app/cli/src/commands/log_command.rs +++ b/src/app/cli/src/commands/log_command.rs @@ -196,7 +196,7 @@ impl AsciiRenderer { )?; match &block.event { - MetadataEvent::SetDataSchema(e @ SetDataSchema { schema: _ }) => { + MetadataEvent::SetDataSchema(e @ SetDataSchema { .. }) => { let schema = e.schema_as_arrow().unwrap(); let schema_str = kamu_data_utils::schema::format::format_schema_arrow(&schema); @@ -343,25 +343,14 @@ impl AsciiRenderer { } self.render_property(output, 0, "WebsiteURL", &e.website_url)?; } - MetadataEvent::SetPollingSource(SetPollingSource { - fetch: _, - prepare: _, - read: _, - preprocess: _, - merge: _, - }) => { + MetadataEvent::SetPollingSource(SetPollingSource { .. }) => { self.render_property(output, 0, "Kind", "SetPollingSource")?; self.render_property(output, 0, "Source", "...")?; } MetadataEvent::DisablePollingSource(_) => { self.render_property(output, 0, "Kind", "DisablePollingSource")?; } - MetadataEvent::AddPushSource(AddPushSource { - source_name, - read: _, - preprocess: _, - merge: _, - }) => { + MetadataEvent::AddPushSource(AddPushSource { source_name, .. }) => { self.render_property(output, 0, "Kind", "AddPushSource")?; self.render_property(output, 0, "SourceName", source_name)?; self.render_property(output, 0, "Source", "...")?; diff --git a/src/app/cli/src/commands/pull_command.rs b/src/app/cli/src/commands/pull_command.rs index 35e43c54a..9668bf237 100644 --- a/src/app/cli/src/commands/pull_command.rs +++ b/src/app/cli/src/commands/pull_command.rs @@ -488,11 +488,9 @@ impl PollingIngestListener for PrettyIngestProgress { )); } PollingIngestResult::Updated { - old_head: _, ref new_head, - num_blocks: _, - has_more: _, uncacheable, + .. } => { if *uncacheable { state @@ -637,11 +635,7 @@ impl TransformListener for PrettyTransformProgress { TransformResult::UpToDate => { console::style("Dataset is up-to-date".to_owned()).yellow() } - TransformResult::Updated { - old_head: _, - ref new_head, - num_blocks: _, - } => console::style(format!( + TransformResult::Updated { ref new_head, .. } => console::style(format!( "Committed new block {}", new_head.as_multibase().short() )) @@ -857,9 +851,9 @@ impl SyncListener for PrettySyncProgress { let msg = match result { SyncResult::UpToDate => console::style("Dataset is up-to-date".to_owned()).yellow(), SyncResult::Updated { - old_head: _, ref new_head, num_blocks, + .. } => console::style(format!( "Updated to {} ({} block(s))", new_head.as_multibase().short(), diff --git a/src/app/cli/src/commands/push_command.rs b/src/app/cli/src/commands/push_command.rs index 043911dfb..8972f37fb 100644 --- a/src/app/cli/src/commands/push_command.rs +++ b/src/app/cli/src/commands/push_command.rs @@ -358,9 +358,9 @@ impl SyncListener for PrettySyncProgress { let msg = match result { SyncResult::UpToDate => console::style("Repository is up-to-date".to_owned()).yellow(), SyncResult::Updated { - old_head: _, ref new_head, num_blocks, + .. } => console::style(format!( "Updated repository to {} ({} block(s))", new_head.as_multibase().short(), diff --git a/src/app/cli/tests/tests/test_system_info_command.rs b/src/app/cli/tests/tests/test_system_info_command.rs index d59381efc..bbddcc7e5 100644 --- a/src/app/cli/tests/tests/test_system_info_command.rs +++ b/src/app/cli/tests/tests/test_system_info_command.rs @@ -40,11 +40,8 @@ async fn test_system_info() { cargo_features: Some(_), cargo_opt_level: Some(_), }, - workspace: WorkspaceInfo { - version: _, - root_dir: _, - }, - container_runtime: ContainerRuntimeInfo { info: _ }, + workspace: WorkspaceInfo { .. }, + container_runtime: ContainerRuntimeInfo { .. }, } ); } diff --git a/src/domain/core/src/services/pull_service.rs b/src/domain/core/src/services/pull_service.rs index 5ee59ac07..25d3e068e 100644 --- a/src/domain/core/src/services/pull_service.rs +++ b/src/domain/core/src/services/pull_service.rs @@ -174,16 +174,12 @@ pub enum PullResult { impl From for PullResult { fn from(other: PollingIngestResult) -> Self { match other { - PollingIngestResult::UpToDate { - no_source_defined: _, - uncacheable: _, - } => PullResult::UpToDate, + PollingIngestResult::UpToDate { .. } => PullResult::UpToDate, PollingIngestResult::Updated { old_head, new_head, num_blocks, - has_more: _, - uncacheable: _, + .. } => PullResult::Updated { old_head: Some(old_head), new_head, diff --git a/src/domain/flow-system/src/entities/flow/flow_state.rs b/src/domain/flow-system/src/entities/flow/flow_state.rs index 9f38ee03a..7f636943c 100644 --- a/src/domain/flow-system/src/entities/flow/flow_state.rs +++ b/src/domain/flow-system/src/entities/flow/flow_state.rs @@ -70,10 +70,10 @@ impl Projection for FlowState { match (state, event) { (None, event) => match event { E::Initiated(FlowEventInitiated { - event_time: _, flow_id, flow_key, trigger, + .. }) => Ok(Self { flow_id, flow_key, @@ -95,9 +95,8 @@ impl Projection for FlowState { match &event { E::Initiated(_) => Err(ProjectionError::new(Some(s), event)), E::StartConditionDefined(FlowEventStartConditionDefined { - event_time: _, - flow_id: _, start_condition, + .. }) => { if s.outcome.is_some() || !s.task_ids.is_empty() { Err(ProjectionError::new(Some(s), event)) @@ -108,11 +107,7 @@ impl Projection for FlowState { }) } } - E::Queued(FlowEventQueued { - event_time: _, - flow_id: _, - activate_at, - }) => { + E::Queued(FlowEventQueued { activate_at, .. }) => { if s.outcome.is_some() || !s.task_ids.is_empty() { Err(ProjectionError::new(Some(s), event)) } else { @@ -125,22 +120,14 @@ impl Projection for FlowState { }) } } - E::TriggerAdded(FlowEventTriggerAdded { - event_time: _, - flow_id: _, - trigger: _, - }) => { + E::TriggerAdded(_) => { if s.outcome.is_some() { Err(ProjectionError::new(Some(s), event)) } else { Ok(s) } } - E::TaskScheduled(FlowEventTaskScheduled { - event_time: _, - flow_id: _, - task_id, - }) => { + E::TaskScheduled(FlowEventTaskScheduled { task_id, .. }) => { if s.outcome.is_some() || s.timing.activate_at.is_none() { Err(ProjectionError::new(Some(s), event)) } else { @@ -152,8 +139,8 @@ impl Projection for FlowState { } E::TaskRunning(FlowEventTaskRunning { event_time, - flow_id: _, task_id, + .. }) => { if s.outcome.is_some() || s.timing.activate_at.is_none() @@ -172,9 +159,9 @@ impl Projection for FlowState { } E::TaskFinished(FlowEventTaskFinished { event_time, - flow_id: _, task_id, task_outcome, + .. }) => { if !s.task_ids.contains(task_id) || s.timing.running_since.is_none() { Err(ProjectionError::new(Some(s), event)) @@ -207,10 +194,7 @@ impl Projection for FlowState { } } } - E::Aborted(FlowEventAborted { - event_time, - flow_id: _, - }) => { + E::Aborted(FlowEventAborted { event_time, .. }) => { if let Some(outcome) = s.outcome { if outcome == FlowOutcome::Success { Err(ProjectionError::new(Some(s), event)) diff --git a/src/domain/flow-system/src/entities/flow_configuration/flow_configuration_state.rs b/src/domain/flow-system/src/entities/flow_configuration/flow_configuration_state.rs index dd637022c..ca63365d1 100644 --- a/src/domain/flow-system/src/entities/flow_configuration/flow_configuration_state.rs +++ b/src/domain/flow-system/src/entities/flow_configuration/flow_configuration_state.rs @@ -41,10 +41,10 @@ impl Projection for FlowConfigurationState { match (state, event) { (None, event) => match event { E::Created(FlowConfigurationEventCreated { - event_time: _, flow_key, paused, rule, + .. }) => Ok(Self { flow_key, status: if paused { @@ -62,12 +62,7 @@ impl Projection for FlowConfigurationState { match &event { E::Created(_) => Err(ProjectionError::new(Some(s), event)), - E::Modified(FlowConfigurationEventModified { - event_time: _, - flow_key: _, - paused, - rule, - }) => { + E::Modified(FlowConfigurationEventModified { paused, rule, .. }) => { // Note: when deleted dataset is re-added with the same id, we have to // gracefully react on this, as if it wasn't a terminal state Ok(FlowConfigurationState { diff --git a/src/domain/task-system/src/entities/task_state.rs b/src/domain/task-system/src/entities/task_state.rs index 782556be2..e4a371d81 100644 --- a/src/domain/task-system/src/entities/task_state.rs +++ b/src/domain/task-system/src/entities/task_state.rs @@ -68,19 +68,18 @@ impl Projection for TaskState { match event { E::TaskCreated(_) => Err(ProjectionError::new(Some(s), event)), - E::TaskRunning(TaskEventRunning { - event_time, - task_id: _, - }) if s.status == TaskStatus::Queued => Ok(Self { - status: TaskStatus::Running, - ran_at: Some(event_time), - ..s - }), - E::TaskCancelled(TaskEventCancelled { - event_time, - task_id: _, - }) if s.status == TaskStatus::Queued - || s.status == TaskStatus::Running && !s.cancellation_requested => + E::TaskRunning(TaskEventRunning { event_time, .. }) + if s.status == TaskStatus::Queued => + { + Ok(Self { + status: TaskStatus::Running, + ran_at: Some(event_time), + ..s + }) + } + E::TaskCancelled(TaskEventCancelled { event_time, .. }) + if s.status == TaskStatus::Queued + || s.status == TaskStatus::Running && !s.cancellation_requested => { Ok(Self { cancellation_requested: true, @@ -90,8 +89,8 @@ impl Projection for TaskState { } E::TaskFinished(TaskEventFinished { event_time, - task_id: _, outcome, + .. }) if s.status == TaskStatus::Queued || s.status == TaskStatus::Running => { Ok(Self { status: TaskStatus::Finished(outcome), diff --git a/src/infra/core/src/ingest/polling_ingest_service_impl.rs b/src/infra/core/src/ingest/polling_ingest_service_impl.rs index d6868f302..424a090b4 100644 --- a/src/infra/core/src/ingest/polling_ingest_service_impl.rs +++ b/src/infra/core/src/ingest/polling_ingest_service_impl.rs @@ -547,10 +547,7 @@ impl PollingIngestServiceImpl { num_blocks, .. }), - PollingIngestResult::UpToDate { - no_source_defined: _, - uncacheable, - }, + PollingIngestResult::UpToDate { uncacheable, .. }, ) => PollingIngestResult::Updated { old_head, new_head, diff --git a/src/infra/core/tests/tests/ingest/test_writer.rs b/src/infra/core/tests/tests/ingest/test_writer.rs index ea23f980d..e847f0a8c 100644 --- a/src/infra/core/tests/tests/ingest/test_writer.rs +++ b/src/infra/core/tests/tests/ingest/test_writer.rs @@ -810,11 +810,11 @@ async fn test_data_writer_builder_scan_no_source() { source_event: None, merge_strategy: odf::MergeStrategy::Append(_), vocab, - data_slices: _, prev_offset: None, prev_checkpoint: None, prev_watermark: None, prev_source_state: None, + .. } if *h == head && vocab.event_time_column == "foo" ); @@ -840,16 +840,15 @@ async fn test_data_writer_builder_scan_polling_source() { assert_matches!( b.metadata_state().unwrap(), DataWriterMetadataState { - head: _, schema: None, source_event: Some(_), merge_strategy: odf::MergeStrategy::Ledger(_), vocab, - data_slices: _, prev_offset: None, prev_checkpoint: None, prev_watermark: None, prev_source_state: None, + .. } if *vocab == odf::DatasetVocabulary::default() ); } @@ -882,16 +881,15 @@ async fn test_data_writer_builder_scan_push_source() { assert_matches!( b.metadata_state().unwrap(), DataWriterMetadataState { - head: _, schema: None, source_event: Some(_), merge_strategy: odf::MergeStrategy::Ledger(_), vocab, - data_slices: _, prev_offset: None, prev_checkpoint: None, prev_watermark: None, prev_source_state: None, + .. } if *vocab == odf::DatasetVocabulary::default() ); } diff --git a/src/infra/core/tests/tests/test_pull_service_impl.rs b/src/infra/core/tests/tests/test_pull_service_impl.rs index a2d57e9f9..99a19ff2c 100644 --- a/src/infra/core/tests/tests/test_pull_service_impl.rs +++ b/src/infra/core/tests/tests/test_pull_service_impl.rs @@ -520,8 +520,8 @@ async fn test_sync_from() { PullResponse { result: Ok(PullResult::Updated { old_head: None, - new_head: _, num_blocks: 1, + .. }), .. } @@ -567,8 +567,8 @@ async fn test_sync_from_url_and_local_ref() { PullResponse { result: Ok(PullResult::Updated { old_head: None, - new_head: _, num_blocks: 1, + .. }), .. } @@ -614,8 +614,8 @@ async fn test_sync_from_url_and_local_multi_tenant_ref() { PullResponse { result: Ok(PullResult::Updated { old_head: None, - new_head: _, num_blocks: 1, + .. }), .. } @@ -661,8 +661,8 @@ async fn test_sync_from_url_only() { PullResponse { result: Ok(PullResult::Updated { old_head: None, - new_head: _, num_blocks: 1, + .. }), .. } @@ -708,8 +708,8 @@ async fn test_sync_from_url_only_multi_tenant_case() { PullResponse { result: Ok(PullResult::Updated { old_head: None, - new_head: _, num_blocks: 1, + .. }), .. } diff --git a/src/infra/core/tests/tests/test_sync_service_impl.rs b/src/infra/core/tests/tests/test_sync_service_impl.rs index 821b470ad..aab974e09 100644 --- a/src/infra/core/tests/tests/test_sync_service_impl.rs +++ b/src/infra/core/tests/tests/test_sync_service_impl.rs @@ -394,7 +394,7 @@ async fn do_test_sync( .await, Err(SyncError::Corrupted(CorruptedSourceError { message, - source: _ + .. })) if message == *"Source checkpoint file is missing" ); } diff --git a/src/infra/core/tests/tests/test_verification_service_impl.rs b/src/infra/core/tests/tests/test_verification_service_impl.rs index 993892e8b..0c86be855 100644 --- a/src/infra/core/tests/tests/test_verification_service_impl.rs +++ b/src/infra/core/tests/tests/test_verification_service_impl.rs @@ -92,8 +92,8 @@ async fn test_verify_data_consistency() { ) .await, VerificationResult { - dataset_handle: _, outcome: Ok(()), + .. } ); @@ -166,8 +166,8 @@ async fn test_verify_data_consistency() { ) .await, VerificationResult { - dataset_handle: _, outcome: Ok(()), + .. } ); @@ -201,7 +201,7 @@ async fn test_verify_data_consistency() { error: DataVerificationError::LogicalHashMismatch { expected, .. }, } )), - dataset_handle: _ + .. } if block_hash == head && expected == data_logical_hash, ); } diff --git a/src/infra/flow-system-inmem/tests/tests/test_flow_configuration_service_inmem.rs b/src/infra/flow-system-inmem/tests/tests/test_flow_configuration_service_inmem.rs index aa93aa9cc..63189cc17 100644 --- a/src/infra/flow-system-inmem/tests/tests/test_flow_configuration_service_inmem.rs +++ b/src/infra/flow-system-inmem/tests/tests/test_flow_configuration_service_inmem.rs @@ -492,9 +492,9 @@ impl FlowConfigurationHarness { assert_matches!( enabled_configurations.get(&(system_flow_type.into())), Some(FlowConfigurationState { - flow_key: _, status: FlowConfigurationStatus::Active, - rule: FlowConfigurationRule::Schedule(actual_schedule) + rule: FlowConfigurationRule::Schedule(actual_schedule), + .. }) if actual_schedule == expected_schedule ); } @@ -509,9 +509,9 @@ impl FlowConfigurationHarness { assert_matches!( enabled_configurations.get(&(FlowKeyDataset::new(dataset_id, dataset_flow_type).into())), Some(FlowConfigurationState { - flow_key: _, status: FlowConfigurationStatus::Active, - rule: FlowConfigurationRule::Schedule(actual_schedule) + rule: FlowConfigurationRule::Schedule(actual_schedule), + .. }) if actual_schedule == expected_schedule ); } diff --git a/src/infra/task-system-inmem/src/task_executor_inmem.rs b/src/infra/task-system-inmem/src/task_executor_inmem.rs index 613886d63..bf4421c18 100644 --- a/src/infra/task-system-inmem/src/task_executor_inmem.rs +++ b/src/infra/task-system-inmem/src/task_executor_inmem.rs @@ -97,9 +97,9 @@ impl TaskExecutor for TaskExecutorInMemory { } } LogicalPlan::Probe(Probe { - dataset_id: _, busy_time, end_with_outcome, + .. }) => { if let Some(busy_time) = busy_time { tokio::time::sleep(*busy_time).await; diff --git a/src/infra/task-system-inmem/tests/tests/test_task_scheduler_inmem.rs b/src/infra/task-system-inmem/tests/tests/test_task_scheduler_inmem.rs index 2213b6bcf..4fc9a26ea 100644 --- a/src/infra/task-system-inmem/tests/tests/test_task_scheduler_inmem.rs +++ b/src/infra/task-system-inmem/tests/tests/test_task_scheduler_inmem.rs @@ -28,14 +28,13 @@ async fn test_creates_task() { .unwrap(); assert_matches!(task_state_actual, TaskState { - task_id: _, status: TaskStatus::Queued, cancellation_requested: false, logical_plan, - created_at: _, ran_at: None, cancellation_requested_at: None, finished_at: None, + .. } if logical_plan == logical_plan_expected); }