-
-
Notifications
You must be signed in to change notification settings - Fork 39
chore: bump edition for all crates to 2024 #163
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Conversation
@@ -277,7 +277,7 @@ pub async fn read_all_pipelines( | |||
/// Helper function to check if an sqlx error is a duplicate pipeline constraint violation | |||
pub fn is_duplicate_pipeline_error(err: &sqlx::Error) -> bool { | |||
match err { | |||
sqlx::Error::Database(ref db_err) => { | |||
sqlx::Error::Database(db_err) => { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Calling out a few places where upgrading the edition caused compiler errors to make it easy to review. The rest of the noise is mostly due to clippy warning fixes or cargo fmt changes.
unsafe { | ||
std::env::set_var("RUST_LOG", "info"); | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Needed due to edition update.
unsafe { | ||
std::env::set_var("RUST_LOG", "info"); | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Needed due to edition update.
std::env::set_var("RUST_LOG", "info"); | ||
unsafe { | ||
std::env::set_var("RUST_LOG", "info"); | ||
} | ||
} |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Needed due to edition update.
let state_store = init_state_store( | ||
replicator_config.pipeline.id, | ||
replicator_config.pipeline.pg_connection.clone(), | ||
) | ||
.await?; |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Needed due to edition update.
pub async fn migrate_state_store(connection_config: PgConnectionConfig) -> Result<(), sqlx::Error> { | ||
pub async fn migrate_state_store( | ||
connection_config: &PgConnectionConfig, | ||
) -> Result<(), sqlx::Error> { | ||
let options: PgConnectOptions = connection_config.with_db(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Needed due to edition update.
This PR:
cargo fmt