Compare commits
3 Commits
461cdb2cc7
...
main
| Author | SHA1 | Date | |
|---|---|---|---|
|
6707e7e403
|
|||
|
9971b46e9e
|
|||
|
302e47c342
|
@@ -6,4 +6,3 @@
|
|||||||
# sleep 10
|
# sleep 10
|
||||||
|
|
||||||
/home/home4/institut_1b/jheuel/repositories/zoidberg/target/release/zoidberg_client
|
/home/home4/institut_1b/jheuel/repositories/zoidberg/target/release/zoidberg_client
|
||||||
|
|
||||||
|
|||||||
@@ -4,12 +4,21 @@ import sys
|
|||||||
import requests
|
import requests
|
||||||
from os import environ
|
from os import environ
|
||||||
|
|
||||||
|
from snakemake.utils import read_job_properties
|
||||||
|
|
||||||
jobscript = sys.argv[1]
|
jobscript = sys.argv[1]
|
||||||
|
job_properties = read_job_properties(jobscript)
|
||||||
|
|
||||||
|
payload = {
|
||||||
|
"cmd": jobscript
|
||||||
|
}
|
||||||
|
|
||||||
|
payload["threads"] = job_properties.get("threads", 1)
|
||||||
|
|
||||||
resp = requests.post(
|
resp = requests.post(
|
||||||
"http://localhost:8080/submit",
|
"http://localhost:8080/submit",
|
||||||
json=[
|
json=[
|
||||||
{"cmd": jobscript},
|
payload,
|
||||||
],
|
],
|
||||||
headers={"cookie": environ["ZOIDBERG_SECRET"]},
|
headers={"cookie": environ["ZOIDBERG_SECRET"]},
|
||||||
)
|
)
|
||||||
|
|||||||
@@ -155,9 +155,8 @@ async fn main() -> Result<(), Box<dyn Error>> {
|
|||||||
std::process::exit(1);
|
std::process::exit(1);
|
||||||
});
|
});
|
||||||
|
|
||||||
let server = std::env::var("ZOIDBERG_SERVER").unwrap_or_else(|_| {
|
let server = std::env::var("ZOIDBERG_SERVER")
|
||||||
String::from(matches.value_of("server").unwrap())
|
.unwrap_or_else(|_| String::from(matches.value_of("server").unwrap()));
|
||||||
});
|
|
||||||
|
|
||||||
let client = Arc::new(
|
let client = Arc::new(
|
||||||
Worker::new(&server, &secret, threads)
|
Worker::new(&server, &secret, threads)
|
||||||
|
|||||||
Reference in New Issue
Block a user