Skip to content

Commit

Permalink
Fixed clippy lints & formatting
Browse files Browse the repository at this point in the history
  • Loading branch information
Kixiron authored and ryzhyk committed Apr 20, 2021
1 parent b0a74ef commit 5f02ba7
Showing 1 changed file with 5 additions and 3 deletions.
8 changes: 5 additions & 3 deletions rust/template/differential_datalog/src/program/worker.rs
Original file line number Diff line number Diff line change
Expand Up @@ -458,16 +458,16 @@ impl<'a> DDlogWorker<'a> {
if let Ok(addr) = ::std::env::var("DIFFERENTIAL_LOG_ADDR") {
if !addr.is_empty() {
if let Ok(stream) = TcpStream::connect(&addr) {
differential_dataflow::logging::enable(self.worker, stream);
// TODO: Use tracing to log that logging connected successfully
differential_dataflow::logging::enable(self.worker, stream);
} else {
panic!("Could not connect to differential log address: {:?}", addr);
}
}
}
}

// Timely already has its logging hooks set by default
// Timely already has its logging hooks set by default
} else if self.config.profiling_kind.is_none() {
self.worker.log_register().remove("timely");
self.worker.log_register().remove("differential/arrange");
Expand Down Expand Up @@ -628,7 +628,8 @@ impl<'a> DDlogWorker<'a> {
}

// TODO: Add back regions for relations
fn render_relation<'a, S>(
#[allow(clippy::clippy::too_many_arguments)]
fn render_relation<S>(
relation: &Relation,
// TODO: Shift to generic representations for ddflow-related structs
scope: &mut S,
Expand Down Expand Up @@ -707,6 +708,7 @@ fn render_relation<'a, S>(
}

// TODO: Regions for SCCs
#[allow(clippy::clippy::too_many_arguments)]
fn render_scc<'a>(
rels: &[RecursiveRelation],
node_id: RelId,
Expand Down

0 comments on commit 5f02ba7

Please sign in to comment.