@@ -64,7 +64,7 @@ def read_integration_creds():
6464
6565
6666def build_config (override , basedir ):
67- randstring = slugid .nice ()[0 :6 ]. decode ( 'utf-8' )
67+ randstring = slugid .nice ()[0 :6 ]
6868 config = get_unfrozen_copy (DEFAULT_CONFIG )
6969 GPG_HOME = os .path .join (os .path .dirname (__file__ ), "data" , "gpg" )
7070 ED25519_DIR = os .path .join (os .path .dirname (__file__ ), "data" , "ed25519" )
@@ -165,8 +165,8 @@ async def remember_cwd():
165165@pytest .mark .parametrize ("context_function" , [get_context , get_temp_creds_context ])
166166@pytest .mark .asyncio
167167async def test_run_successful_task (context_function ):
168- task_id = slugid .nice (). decode ( 'utf-8' )
169- task_group_id = slugid .nice (). decode ( 'utf-8' )
168+ task_id = slugid .nice ()
169+ task_group_id = slugid .nice ()
170170 async with context_function (None ) as context :
171171 result = await create_task (context , task_id , task_group_id )
172172 assert result ['status' ]['state' ] == 'pending'
@@ -183,7 +183,7 @@ async def test_run_successful_task(context_function):
183183@pytest .mark .parametrize ("context_function" , [get_context , get_temp_creds_context ])
184184@pytest .mark .asyncio
185185async def test_run_maxtimeout (context_function ):
186- task_id = slugid .nice (). decode ( 'utf-8' )
186+ task_id = slugid .nice ()
187187 partial_config = {
188188 'task_max_timeout' : 2 ,
189189 'task_script' : ('bash' , '-c' , '>&2 echo bar && echo foo && sleep 30 && exit 1' ),
@@ -220,7 +220,7 @@ async def run_task_until_stopped(context):
220220@pytest .mark .skipif (os .environ .get ("NO_TESTS_OVER_WIRE" ), reason = SKIP_REASON )
221221@pytest .mark .asyncio
222222async def test_cancel_task ():
223- task_id = slugid .nice (). decode ( 'utf-8' )
223+ task_id = slugid .nice ()
224224 partial_config = {
225225 'invalid_reclaim_status' : 19 ,
226226 'task_script' : ('bash' , '-c' , '>&2 echo bar && echo foo && sleep 30 && exit 1' ),
@@ -263,7 +263,7 @@ async def do_shutdown(context):
263263@pytest .mark .skipif (os .environ .get ("NO_TESTS_OVER_WIRE" ), reason = SKIP_REASON )
264264@pytest .mark .asyncio
265265async def test_shutdown ():
266- task_id = slugid .nice (). decode ( 'utf-8' )
266+ task_id = slugid .nice ()
267267 partial_config = {
268268 'task_script' : ('bash' , '-c' , '>&2 echo running task script && sleep 30 && exit 1' ),
269269 }
@@ -426,7 +426,7 @@ async def verify_cot(name, task_id, task_type):
426426@pytest .mark .parametrize ("context_function" , [get_context , get_temp_creds_context ])
427427@pytest .mark .asyncio
428428async def test_private_artifacts (context_function ):
429- task_group_id = task_id = slugid .nice (). decode ( 'utf-8' )
429+ task_group_id = task_id = slugid .nice ()
430430 override = {
431431 'task_script' : (
432432 'bash' , '-c' ,
0 commit comments