2
0
Fork 0
mirror of https://git.asonix.dog/asonix/pict-rs synced 2024-11-20 11:21:14 +00:00
This commit is contained in:
asonix 2024-02-03 18:30:52 -06:00
parent 880dfc20ee
commit c176e4c686
6 changed files with 4 additions and 14 deletions

View file

@ -93,7 +93,6 @@ pub(crate) async fn generate<S: Store + 'static>(
} }
} }
#[allow(clippy::too_many_arguments)]
#[tracing::instrument(skip(state, hash))] #[tracing::instrument(skip(state, hash))]
async fn process<S: Store + 'static>( async fn process<S: Store + 'static>(
state: &State<S>, state: &State<S>,
@ -167,7 +166,6 @@ async fn process<S: Store + 'static>(
Ok((details, bytes)) as Result<(Details, Bytes), Error> Ok((details, bytes)) as Result<(Details, Bytes), Error>
} }
#[allow(clippy::too_many_arguments)]
#[tracing::instrument(skip_all)] #[tracing::instrument(skip_all)]
async fn input_identifier<S>( async fn input_identifier<S>(
state: &State<S>, state: &State<S>,
@ -220,7 +218,7 @@ where
}; };
let reader = ffmpeg::thumbnail( let reader = ffmpeg::thumbnail(
&state, state,
identifier, identifier,
original_details original_details
.video_format() .video_format()

View file

@ -160,7 +160,6 @@ where
Ok((input_type, identifier, details, hash_state)) Ok((input_type, identifier, details, hash_state))
} }
#[allow(clippy::too_many_arguments)]
#[tracing::instrument(skip(state, stream))] #[tracing::instrument(skip(state, stream))]
pub(crate) async fn ingest<S>( pub(crate) async fn ingest<S>(
state: &State<S>, state: &State<S>,

View file

@ -773,7 +773,6 @@ async fn not_found_hash(repo: &ArcRepo) -> Result<Option<(Alias, Hash)>, Error>
} }
/// Process files /// Process files
#[allow(clippy::too_many_arguments)]
#[tracing::instrument(name = "Serving processed image", skip(state, process_map))] #[tracing::instrument(name = "Serving processed image", skip(state, process_map))]
async fn process<S: Store + 'static>( async fn process<S: Store + 'static>(
range: Option<web::Header<Range>>, range: Option<web::Header<Range>>,
@ -899,7 +898,6 @@ async fn process<S: Store + 'static>(
)) ))
} }
#[allow(clippy::too_many_arguments)]
#[tracing::instrument(name = "Serving processed image headers", skip(state))] #[tracing::instrument(name = "Serving processed image headers", skip(state))]
async fn process_head<S: Store + 'static>( async fn process_head<S: Store + 'static>(
range: Option<web::Header<Range>>, range: Option<web::Header<Range>>,
@ -1042,7 +1040,6 @@ async fn details<S: Store + 'static>(
} }
/// Serve files based on alias query /// Serve files based on alias query
#[allow(clippy::too_many_arguments)]
#[tracing::instrument(name = "Serving file query", skip(state))] #[tracing::instrument(name = "Serving file query", skip(state))]
async fn serve_query<S: Store + 'static>( async fn serve_query<S: Store + 'static>(
range: Option<web::Header<Range>>, range: Option<web::Header<Range>>,

View file

@ -17,7 +17,6 @@ use crate::{
store::Store, store::Store,
}; };
#[allow(clippy::too_many_arguments)]
pub(super) async fn migrate_store<S1, S2>( pub(super) async fn migrate_store<S1, S2>(
from: S1, from: S1,
to: State<S2>, to: State<S2>,
@ -75,7 +74,6 @@ struct MigrateState<S1, S2> {
started_at: Instant, started_at: Instant,
} }
#[allow(clippy::too_many_arguments)]
async fn do_migrate_store<S1, S2>( async fn do_migrate_store<S1, S2>(
from: S1, from: S1,
to: State<S2>, to: State<S2>,
@ -326,7 +324,6 @@ where
Ok(()) Ok(())
} }
#[allow(clippy::too_many_arguments)]
async fn migrate_file<S1, S2>( async fn migrate_file<S1, S2>(
from: &S1, from: &S1,
to: &State<S2>, to: &State<S2>,

View file

@ -330,7 +330,6 @@ async fn process_image_jobs<S, F>(
} }
} }
#[allow(clippy::too_many_arguments)]
async fn image_job_loop<S, F>( async fn image_job_loop<S, F>(
state: &State<S>, state: &State<S>,
process_map: &ProcessMap, process_map: &ProcessMap,

View file

@ -14,10 +14,10 @@ use crate::{
store::Store, store::Store,
}; };
pub(super) fn perform<'a, S>( pub(super) fn perform<S>(
state: &'a State<S>, state: &State<S>,
job: serde_json::Value, job: serde_json::Value,
) -> LocalBoxFuture<'a, Result<(), Error>> ) -> LocalBoxFuture<'_, Result<(), Error>>
where where
S: Store + 'static, S: Store + 'static,
{ {