asonix/background-jobs
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Remove dependency on tracing-futures

Browse source
This commit is contained in:
asonix 2024-01-08 16:37:32 -06:00
parent 51418ced0e
commit dc3f7b2c62
6 changed files with 4 additions and 10 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
jobs-actix/Cargo.toml
View file

@ -16,7 +16,6 @@ async-trait = "0.1.24"
background-jobs-core = { version = "0.17.0", path = "../jobs-core" } background-jobs-core = { version = "0.17.0", path = "../jobs-core" }
metrics = "0.22.0" metrics = "0.22.0"
tracing = "0.1" tracing = "0.1"
tracing-futures = "0.2"
serde = { version = "1.0", features = ["derive"] } serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0" serde_json = "1.0"
thiserror = "1.0" thiserror = "1.0"

3
jobs-actix/src/worker.rs
View file

@ -1,8 +1,7 @@
use crate::Server; use crate::Server;
use background_jobs_core::CachedProcessorMap; use background_jobs_core::CachedProcessorMap;
use std::future::Future; use std::future::Future;
use tracing::Span; use tracing::{Instrument, Span};
use tracing_futures::Instrument;
use uuid::Uuid; use uuid::Uuid;
struct LocalWorkerStarter<State: Clone + 'static, Extras: 'static> { struct LocalWorkerStarter<State: Clone + 'static, Extras: 'static> {

1
jobs-core/Cargo.toml
View file

@ -21,7 +21,6 @@ event-listener = "4"
metrics = "0.22.0" metrics = "0.22.0"
time = { version = "0.3", features = ["serde-human-readable"] } time = { version = "0.3", features = ["serde-human-readable"] }
tracing = "0.1" tracing = "0.1"
tracing-futures = "0.2.5"
serde = { version = "1.0", features = ["derive"] } serde = { version = "1.0", features = ["derive"] }
serde_json = "1.0" serde_json = "1.0"
thiserror = "1.0" thiserror = "1.0"

3
jobs-core/src/job.rs
View file

@ -3,8 +3,7 @@ use anyhow::Error;
use serde::{de::DeserializeOwned, ser::Serialize}; use serde::{de::DeserializeOwned, ser::Serialize};
use serde_json::Value; use serde_json::Value;
use std::{future::Future, pin::Pin, time::SystemTime}; use std::{future::Future, pin::Pin, time::SystemTime};
use tracing::Span; use tracing::{Instrument, Span};
use tracing_futures::Instrument;
/// The Job trait defines parameters pertaining to an instance of background job /// The Job trait defines parameters pertaining to an instance of background job
/// ///

3
jobs-core/src/processor_map.rs
View file

@ -4,8 +4,7 @@ use std::{
collections::HashMap, future::Future, panic::AssertUnwindSafe, pin::Pin, sync::Arc, collections::HashMap, future::Future, panic::AssertUnwindSafe, pin::Pin, sync::Arc,
time::Instant, time::Instant,
}; };
use tracing::Span; use tracing::{Instrument, Span};
use tracing_futures::Instrument;
use uuid::Uuid; use uuid::Uuid;
/// A generic function that processes a job /// A generic function that processes a job

3
jobs-core/src/unsend_job.rs
View file

@ -7,8 +7,7 @@ use std::{
pin::Pin, pin::Pin,
task::{Context, Poll}, task::{Context, Poll},
}; };
use tracing::Span; use tracing::{Instrument, Span};
use tracing_futures::Instrument;
#[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord, Hash)] #[derive(Clone, Copy, Debug, PartialEq, Eq, PartialOrd, Ord, Hash)]
/// The type produced when a task is dropped before completion as a result of being deliberately /// The type produced when a task is dropped before completion as a result of being deliberately