@ -1,4 +1,4 @@
# Copyright (C) 2020 Intel Corporation
# Copyright (C) 2020 -2021 Intel Corporation
#
# SPDX-License-Identifier: MIT
@ -23,7 +23,7 @@ class CLI():
self . session = session
self . login ( credentials )
def tasks_data ( self , task_id , resource_type , resources ):
def tasks_data ( self , task_id , resource_type , resources , * * kwargs ):
""" Add local, remote, or shared files to an existing task. """
url = self . api . tasks_id_data ( task_id )
data = { }
@ -35,6 +35,13 @@ class CLI():
elif resource_type == ResourceType . SHARE :
data = { ' server_files[ {} ] ' . format ( i ) : f for i , f in enumerate ( resources ) }
data [ ' image_quality ' ] = 50
## capture additional kwargs
if ' image_quality ' in kwargs :
data [ ' image_quality ' ] = kwargs . get ( ' image_quality ' )
if ' frame_step ' in kwargs :
data [ ' frame_filter ' ] = f " step= { kwargs . get ( ' frame_step ' ) } "
response = self . session . post ( url , data = data , files = files )
response . raise_for_status ( )
@ -85,7 +92,7 @@ class CLI():
response_json = response . json ( )
log . info ( ' Created task ID: {id} NAME: {name} ' . format ( * * response_json ) )
task_id = response_json [ ' id ' ]
self . tasks_data ( task_id , resource_type , resources )
self . tasks_data ( task_id , resource_type , resources , * * kwargs )
if annotation_path != ' ' :
url = self . api . tasks_id_status ( task_id )