pijul/nest - Change IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC

Avoid saving the result

Created by pmeunier on June 7, 2026

IS5JL73JHDDJQGGGYBUUJNEBFT3STOKGB7V33M6J44CB2TPOVPXQC

Dependencies

In channels

main

Change contents

Replacement in ci/src/main.rs at line 49 [2.65]

B:BD[4.5240] → [4.5240:5316]

                    tokio::sync::watch::Receiver<std::option::Option<i32>>,

[4.5240]

[4.5316]

                    tokio::sync::watch::Receiver<std::option::Option<Status>>,

Replacement in ci/src/main.rs at line 89 [2.65]

B:BD[4.6084] → [4.6084:6235]

    let s =
        tokio::fs::read_to_string(&config.config.ci_path.join(&format!("{}.status", job))).await?;
    Ok(Json(serde_json::from_str(&s)?))

[4.6084]

[2.2720]

    if let Some((_, job)) = config.jobs.lock().unwrap().get(&job) {
        if let Some(s) = &*job.borrow() {
            return Ok(Json(s.clone()));
        }
    }
    Err(Error::NotFound)

Deletion in ci/src/main.rs at line 260 [2.65]
B:BD[4.11169] → [4.11169:11192]
```
            status_tx,
```

Replacement in ci/src/main.rs at line 264 [2.65]

B:BD[2.11139] → [4.11270:11499]

        let (code, results) = result?;
        debug!("code = {:?} {:?}", code, results);
        tokio::fs::write(
            config.config.ci_path.join(&format!("{}.status", t.id)),
            serde_json::to_string(&Status {

[2.11139]

[4.11499]

        if let Ok((code, results)) = result {
            let status = Status {

Replacement in ci/src/main.rs at line 269 [2.65]

B:BD[4.11592] → [4.11592:11657]

            })
            .unwrap(),
        )
        .await?;

[4.11592]

[4.11657]

            };
            status_tx.send(Some(status)).unwrap();
        } else {
            let status = Status {
                code: None,
                results: HashMap::new(),
                finished: chrono::Utc::now(),
            };
            status_tx.send(Some(status)).unwrap();
        }

Deletion in ci/src/main.rs at line 290 [2.65]
B:BD[4.11908] → [4.11908:11968]
```
    mut status_tx: tokio::sync::watch::Sender<Option<i32>>,
```

Replacement in ci/src/main.rs at line 324 [2.65]

B:BD[4.12957] → [4.12957:13036]

    let code = dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx).await?;

[4.12957]

[2.14104]

    let code = dump_cmd(cmd, &mut files, &mut kill_rx).await?;

Replacement in ci/src/main.rs at line 356 [2.65]

B:BD[4.14053] → [4.14053:14173]

        Ok((
            dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx).await?,
            result,
        ))

[4.14053]

[4.14173]

        Ok((dump_cmd(cmd, &mut files, &mut kill_rx).await?, result))

Replacement in ci/src/lib.rs at line 6 [2.14618]
B:BD[2.14641] → [4.14314:14355]
```
#[derive(Debug, Serialize, Deserialize)]
```
[2.14641]
[4.14355]
```
#[derive(Clone, Debug, Serialize, Deserialize)]
```
Deletion in ci/src/lib.rs at line 28 [2.14618]
B:BD[4.14881] → [4.14881:14942]
```
    status_tx: &mut tokio::sync::watch::Sender<Option<i32>>,
```
Deletion in ci/src/lib.rs at line 107 [2.14618]
B:BD[4.17915] → [4.17915:17958]
```
            status_tx.send(code).unwrap();
```

Replacement in api/src/replication.rs at line 421 [5.431834]

B:BD[4.44709] → [4.44709:44781]

        let status = if let reqwest::StatusCode::OK = status.status() {

[4.44709]

[4.44781]

        let code = status.status();
        let status = if let reqwest::StatusCode::OK = code {

Insertion in api/src/replication.rs at line 435 [5.431834]

[4.45235]

[3.4015]

        } else if let reqwest::StatusCode::NOT_FOUND = code {
            use crate::db::jobs::dsl as jobs;
            diesel::update(jobs::jobs.find(job))
                .set((
                    jobs::status.eq(None::<i32>),
                    jobs::ended.eq(chrono::Utc::now()),
                ))
                .execute(db)
                .await
                .unwrap();
            break;

Replacement in api/src/replication.rs at line 473 [5.431834]

B:BD[4.46261] → [4.46261:46342]

            let (mut status_tx, _status_rx) = tokio::sync::watch::channel(None);

[4.46261]

[4.46342]

            let (mut status_tx, _status_rx) = tokio::sync::watch::channel(None::<i32>);

Deletion in api/src/replication.rs at line 483 [5.431834]

B:BD[4.46773] → [4.46773:46907]

                    .unwrap();
                ci::dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx)
                    .await

Insertion in api/src/replication.rs at line 484 [5.431834]

[4.46938]

[3.6417]

                ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();

Deletion in api/src/replication.rs at line 493 [5.431834]

B:BD[4.47307] → [4.47307:47441]

                    .unwrap();
                ci::dump_cmd(cmd, &mut files, &mut kill_rx, &mut status_tx)
                    .await

Insertion in api/src/replication.rs at line 494 [5.431834]

[4.47472]

[3.6516]

                ci::dump_cmd(cmd, &mut files, &mut kill_rx).await.unwrap();

Replacement in api/src/jobs.rs at line 200 [6.32096]

B:BD[4.51315] → [4.51315:51399]

            crate::replication::get_config_state(&config.repo_locks, repo, channel)

[4.51315]

[4.51399]

            crate::replication::get_config_state(&config.repo_locks, repo, channel.clone())

Insertion in api/src/jobs.rs at line 218 [6.32096]
[4.52062]
[4.52062]
```
                channel,
```