Add several flags to task_create CLI

CHANGELOG.md

@@ -29,6 +29,7 @@ and this project adheres to [Semantic Versioning](https://semver.org/spec/v2.0.0
 - Support for uploading manifest with any name (<https://github.com/openvinotoolkit/cvat/pull/4041>)
 - Added information about OpenVINO toolkit to login page (<https://github.com/openvinotoolkit/cvat/pull/4077>)
 - Support for working with ellipses (<https://github.com/openvinotoolkit/cvat/pull/4062>)
+- Add several flags to task creation CLI (<https://github.com/openvinotoolkit/cvat/pull/4119>)
 
 ### Changed
 - Users don't have access to a task object anymore if they are assigneed only on some jobs of the task (<https://github.com/openvinotoolkit/cvat/pull/3788>)

utils/cli/core/core.py

@@ -34,19 +34,15 @@ def tasks_data(self, task_id, resource_type, resources, **kwargs):
             data = {'remote_files[{}]'.format(i): f for i, f in enumerate(resources)}
         elif resource_type == ResourceType.SHARE:
             data = {'server_files[{}]'.format(i): f for i, f in enumerate(resources)}
-        data['image_quality'] = 50
+        data['image_quality'] = 70
 
         ## capture additional kwargs
-        if 'image_quality' in kwargs:
-            data['image_quality'] = kwargs.get('image_quality')
-        if 'frame_step' in kwargs:
+        for flag in ['chunk_size', 'copy_data', 'image_quality', 'sorting_method',
+                    'start_frame', 'stop_frame', 'use_cache', 'use_zip_chunks']:
+            if kwargs.get(flag) is not None:
+                data[flag] = kwargs.get(flag)
+        if kwargs.get('frame_step') is not None:
             data['frame_filter'] = f"step={kwargs.get('frame_step')}"
-        if 'copy_data' in kwargs:
-            data['copy_data'] = kwargs.get('copy_data')
-        if 'use_cache' in kwargs:
-            data['use_cache'] = kwargs.get('use_cache')
-        if 'sorting_method' in kwargs:
-            data['sorting_method'] = kwargs.get('sorting_method')
 
         response = self.session.post(url, data=data, files=files)
         response.raise_for_status()
@@ -76,25 +72,24 @@ def tasks_list(self, use_json_output, **kwargs):
             response.raise_for_status()
         return output
 
-    def tasks_create(self, name, labels, overlap, segment_size, bug, resource_type, resources,
+    def tasks_create(self, name, labels, resource_type, resources,
                      annotation_path='', annotation_format='CVAT XML 1.1',
                      completion_verification_period=20,
                      git_completion_verification_period=2,
                      dataset_repository_url='',
-                     project_id=None,
                      lfs=False, **kwargs):
         """ Create a new task with the given name and labels JSON and
         add the files to it. """
         url = self.api.tasks
-        labels = [] if project_id is not None else labels
+        labels = [] if kwargs.get('project_id') is not None else labels
         data = {'name': name,
-                'labels': labels,
-                'overlap': overlap,
-                'segment_size': segment_size,
-                'bug_tracker': bug,
+                'labels': labels
         }
-        if project_id:
-            data.update({'project_id': project_id})
+
+        for flag in ['bug_tracker', 'overlap', 'project_id', 'segment_size']:
+            if kwargs.get(flag) is not None:
+                data[flag] = kwargs.get(flag)
+
         response = self.session.post(url, json=data)
         response.raise_for_status()
         response_json = response.json()

utils/cli/core/definition.py

@@ -1,3 +1,5 @@
+# Copyright (C) 2021 Intel Corporation
+#
 # SPDX-License-Identifier: MIT
 import argparse
 import getpass
@@ -106,36 +108,6 @@ def argparse(s):
     type=str,
     help='name of the task'
 )
-task_create_parser.add_argument(
-    '--labels',
-    default='[]',
-    type=parse_label_arg,
-    help='string or file containing JSON labels specification'
-)
-task_create_parser.add_argument(
-    '--project_id',
-    default=None,
-    type=int,
-    help='project ID if project exists'
-)
-task_create_parser.add_argument(
-    '--overlap',
-    default=0,
-    type=int,
-    help='the number of intersected frames between different segments'
-)
-task_create_parser.add_argument(
-    '--segment_size',
-    default=0,
-    type=int,
-    help='the number of frames in a segment'
-)
-task_create_parser.add_argument(
-    '--bug',
-    default='',
-    type=str,
-    help='bug tracker URL'
-)
 task_create_parser.add_argument(
     'resource_type',
     default='local',
@@ -161,13 +133,32 @@ def argparse(s):
     type=str,
     help='format of the annotation file being uploaded, e.g. CVAT 1.1'
 )
+task_create_parser.add_argument(
+    '--bug_tracker', '--bug',
+    default=None,
+    type=str,
+    help='bug tracker URL'
+)
+task_create_parser.add_argument(
+    '--chunk_size',
+    default=None,
+    type=int,
+    help='the number of frames per chunk'
+)
 task_create_parser.add_argument(
     '--completion_verification_period',
     default=20,
     type=int,
     help='''number of seconds to wait until checking
             if data compression finished (necessary before uploading annotations)'''
 )
+task_create_parser.add_argument(
+    '--copy_data',
+    default=False,
+    action='store_true',
+    help='''set the option to copy the data, only used when resource type is
+            share (default: %(default)s)'''
+)
 task_create_parser.add_argument(
     '--dataset_repository_url',
     default='',
@@ -176,10 +167,11 @@ def argparse(s):
           ' https://github.com/user/repos [annotation/<anno_file_name.zip>]')
 )
 task_create_parser.add_argument(
-    '--lfs',
-    default=False,
-    action='store_true',
-    help='using lfs for dataset repository (default: %(default)s)'
+    '--frame_step',
+    default=None,
+    type=int,
+    help='''set the frame step option in the advanced configuration
+            when uploading image series or videos (default: %(default)s)'''
 )
 task_create_parser.add_argument(
     '--image_quality',
@@ -189,31 +181,63 @@ def argparse(s):
             when creating tasks.(default: %(default)s)'''
 )
 task_create_parser.add_argument(
-    '--frame_step',
-    default=1,
-    type=int,
-    help='''set the frame step option in the advanced configuration
-            when uploading image series or videos (default: %(default)s)'''
+    '--labels',
+    default='[]',
+    type=parse_label_arg,
+    help='string or file containing JSON labels specification'
 )
 task_create_parser.add_argument(
-    '--copy_data',
+    '--lfs',
     default=False,
     action='store_true',
-    help='''set the option to copy the data, only used when resource type is
-            share (default: %(default)s)'''
+    help='using lfs for dataset repository (default: %(default)s)'
 )
 task_create_parser.add_argument(
-    '--use_cache',
-    default=True,
-    action='store_false',
-    help='''set the option to use the cache (default: %(default)s)'''
+    '--project_id',
+    default=None,
+    type=int,
+    help='project ID if project exists'
+)
+task_create_parser.add_argument(
+    '--overlap',
+    default=None,
+    type=int,
+    help='the number of intersected frames between different segments'
+)
+task_create_parser.add_argument(
+    '--segment_size',
+    default=None,
+    type=int,
+    help='the number of frames in a segment'
 )
 task_create_parser.add_argument(
     '--sorting-method',
     default='lexicographical',
     choices=['lexicographical', 'natural', 'predefined', 'random'],
     help='''data soring method (default: %(default)s)'''
 )
+task_create_parser.add_argument(
+    '--start_frame',
+    default=None,
+    type=int,
+    help='the start frame of the video'
+)
+task_create_parser.add_argument(
+    '--stop_frame',
+    default=None,
+    type=int,
+    help='the stop frame of the video'
+)
+task_create_parser.add_argument(
+    '--use_cache',
+    action='store_true',  # automatically sets default=False
+    help='''use cache'''
+)
+task_create_parser.add_argument(
+    '--use_zip_chunks',
+    action='store_true',  # automatically sets default=False
+    help='''zip chunks before sending them to the server'''
+)
 
 #######################################################################
 # Delete

utils/cli/tests/test_cli.py

@@ -27,7 +27,6 @@ def setUp(self, mock_stdout):
         self.taskname = 'test_task'
         self.cli.tasks_create(self.taskname,
                               [{'name' : 'car'}, {'name': 'person'}],
-                              0, 0, '',
                               ResourceType.LOCAL,
                               [self.img_file])
         # redirect logging to mocked stdout to test program output