1. import datetime
  3. def decode_schedule(schedule_string):
  4. """
  5. Decodes a schedule string into a list of tuples representing scheduled runs.
  6. Each tuple contains the run time (datetime object) and the run identifier (string).
  8. Args:
  9. schedule_string: A string representing the schedule.
  10. Format: "run1:YYYY-MM-DD HH:MM:SS,run2:YYYY-MM-DD HH:MM:SS,..."
  12. Returns:
  13. A list of tuples, where each tuple is (datetime object, run_id).
  14. Returns an empty list if the input string is empty.
  15. """
  16. if not schedule_string:
  17. return []
  19. runs = []
  20. run_entries = schedule_string.split(',')
  21. for entry in run_entries:
  22. try:
  23. run_id, time_str = entry.split(':')
  24. run_id = run_id.strip()
  25. time_str = time_str.strip()
  26. run_time = datetime.datetime.strptime(time_str, "%Y-%m-%d %H:%M:%S")
  27. runs.append((run_time, run_id))
  28. except ValueError:
  29. print(f"Warning: Invalid schedule entry: {entry}. Skipping.") #Handle potential errors gracefully
  30. continue
  32. return runs
  34. if __name__ == '__main__':
  35. schedule = "run1:2024-01-01 10:00:00,run2:2024-01-02 14:30:00,invalid_entry"
  36. decoded_schedule = decode_schedule(schedule)
  37. print(decoded_schedule)
  39. schedule2 = ""
  40. decoded_schedule2 = decode_schedule(schedule2)
  41. print(decoded_schedule2)

Add your comment