Skip to content

Commit

Permalink
fmt
Browse files Browse the repository at this point in the history
  • Loading branch information
wenym1 committed Oct 23, 2023
1 parent 577c5cb commit 31f6024
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions src/meta/src/manager/sink_coordination/manager.rs
Original file line number Diff line number Diff line change
Expand Up @@ -362,12 +362,11 @@ mod tests {
use risingwave_pb::connector_service::sink_metadata::{Metadata, SerializedMetadata};
use risingwave_pb::connector_service::SinkMetadata;
use risingwave_rpc_client::CoordinatorStreamHandle;
use risingwave_sink_impl as _;

use crate::manager::sink_coordination::coordinator_worker::CoordinatorWorker;
use crate::manager::sink_coordination::{NewSinkWriterRequest, SinkCoordinatorManager};

use risingwave_sink_impl as _;

struct MockCoordinator<C, F: FnMut(u64, Vec<SinkMetadata>, &mut C) -> Result<(), SinkError>> {
context: C,
f: F,
Expand Down

0 comments on commit 31f6024

Please sign in to comment.