def sync(self):
    from utils.task_helpers import sync
    parser = ArgParseDefault(description='Sync project data from S3')
    parser.add_argument('-s', '--source', choices=['all', 'streaming', 'annotation', 'media'], required=False, default='all', help='Type of data to be synced. By default sync all data belonging to this project.')
    parser.add_argument('-l', '--last', required=False, type=int, help='Sync streaming data of last n days')
    args = parser.parse_args(sys.argv[2:])
    sync(data_type=args.source, last_n_days=args.last)
def sync(self):
    from utils.task_helpers import sync
    parser = ArgParseDefault(description='Sync project data from S3')
    parser.add_argument('-s', '--source', choices=['all', 'streaming', 'annotation', 'media'], required=False, default='all', help='Type of data to be synced. By default sync all data belonging to this project.')
    parser.add_argument('-l', '--last', required=False, type=int, help='Sync streaming data of last n days')
    args = parser.parse_args(sys.argv[2:])
    sync(data_type=args.source, last_n_days=args.last)