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