1212from packaging .version import Version
1313from uuid import UUID
1414
15- DEFAULT_TIMEOUT_SECONDS = 10 * 60 # 10 min
15+ DEFAULT_TIMEOUT_SECONDS = 15 * 60 # 10 min
1616
1717
1818@skip_if_osparc_version (at_least = Version ("0.8.3.post0.dev20" ))
@@ -62,11 +62,17 @@ async def test_logstreaming(
6262):
6363 """Test log streaming"""
6464 solvers_api : osparc .SolversApi = osparc .SolversApi (api_client )
65- job : osparc . Job = solvers_api .create_job (
65+ job , _ , headers = solvers_api .create_job_with_http_info (
6666 sleeper .id , sleeper .version , osparc .JobInputs ({"input1" : 1.0 })
67- ) # type: ignore
67+ )
68+ print (headers )
69+ assert isinstance (job , osparc .Job )
70+ print (job )
6871
69- solvers_api .start_job (sleeper .id , sleeper .version , job .id )
72+ _ , _ , headers = solvers_api .start_job_with_http_info (
73+ sleeper .id , sleeper .version , job .id
74+ )
75+ print (headers )
7076
7177 nloglines : int = 0
7278 url = f"/v0/solvers/{ sleeper .id } /releases/{ sleeper .version } /jobs/{ job .id } /logstream"
@@ -77,6 +83,7 @@ async def test_logstreaming(
7783 url ,
7884 timeout = DEFAULT_TIMEOUT_SECONDS ,
7985 ) as response :
86+ print (response .headers )
8087 async for line in response .aiter_lines ():
8188 log = json .loads (line )
8289 job_id = log .get ("job_id" )
@@ -86,9 +93,8 @@ async def test_logstreaming(
8693 ) # keep test backwards compatible
8794 nloglines += 1
8895 print ("\n " .join (log .get ("messages" )))
89- if nloglines > 10 : # dont wait too long
90- await response .aclose ()
91- break
96+ await response .aclose ()
97+ break
9298
9399 assert nloglines > 0 , f"Could not stream log for { sleeper .id = } , \
94100 { sleeper .version = } and { job .id = } " # type: ignore
0 commit comments