VERSION_2_4_0 = six.u('2.4.0')
VERSION_2_4_1 = six.u('2.4.1')
VERSION_2_4_2 = six.u('2.4.2')
+VERSION_2_4_3 = six.u('2.4.3')
logger = logging.getLogger(__name__)
local_zone = tzlocal.get_localzone()
# If the value is already localized, there is no need to change
# time zone at this point. Also None is a valid value too.
localized = value
- elif isinstance(value, six.string_types):
+ elif (isinstance(value, six.string_types)
+ and self.warrior.version >= VERSION_2_4_0):
# For strings, use 'task calc' to evaluate the string to datetime
+ # available since TW 2.4.0
args = value.split()
result = self.warrior.execute_command(['calc'] + args)
naive = datetime.datetime.strptime(result[0], DATE_FORMAT_CALC)
def pending(self):
return self['status'] == six.text_type('pending')
+ @property
+ def active(self):
+ return self['start'] is not None
+
@property
def saved(self):
return self['uuid'] is not None or self['id'] is not None
class TaskWarrior(object):
- def __init__(self, data_location='~/.task', create=True, taskrc_location='~/.taskrc'):
- data_location = os.path.expanduser(data_location)
+ def __init__(self, data_location=None, create=True, taskrc_location='~/.taskrc'):
self.taskrc_location = os.path.expanduser(taskrc_location)
# If taskrc does not exist, pass / to use defaults and avoid creating
if not os.path.exists(self.taskrc_location):
self.taskrc_location = '/'
- if create and not os.path.exists(data_location):
- os.makedirs(data_location)
-
+ self.version = self._get_version()
self.config = {
- 'data.location': data_location,
'confirmation': 'no',
'dependency.confirmation': 'no', # See TW-1483 or taskrc man page
'recurrence.confirmation': 'no', # Necessary for modifying R tasks
+ # 2.4.3 onwards supports 0 as infite bulk, otherwise set just
+ # arbitrary big number which is likely to be large enough
+ 'bulk': 0 if self.version >= VERSION_2_4_3 else 100000,
}
+
+ # Set data.location override if passed via kwarg
+ if data_location is not None:
+ data_location = os.path.expanduser(data_location)
+ if create and not os.path.exists(data_location):
+ os.makedirs(data_location)
+ self.config['data.location'] = data_location
+
self.tasks = TaskQuerySet(self)
- self.version = self._get_version()
def _get_command_args(self, args, config_override={}):
command_args = ['task', 'rc:{0}'.format(self.taskrc_location)]
else:
error_msg = stdout.strip()
raise TaskWarriorException(error_msg)
- return stdout.strip().split('\n')
+ return stdout.rstrip().split('\n')
def enforce_recurrence(self):
# Run arbitrary report command which will trigger generation