1. import datetime
  3. def compare_maintenance_tasks(tasks):
  4. """
  5. Compares values of form fields for maintenance tasks with fixed retry intervals.
  7. Args:
  8. tasks (list): A list of dictionaries, where each dictionary represents a
  9. maintenance task. Each task should have:
  10. - 'task_id': Unique identifier for the task (int).
  11. - 'last_attempt': Datetime of the last attempt (datetime).
  12. - 'retry_interval_days': Number of days to wait before retrying (int).
  13. - 'field1': Value of the first form field (str).
  14. - 'field2': Value of the second form field (int).
  15. - ... other fields as needed.
  17. Returns:
  18. list: A list of dictionaries, where each dictionary contains information about
  19. tasks that need to be retried, including the task ID, the reason for retry,
  20. and the next retry time. Returns an empty list if no tasks need retry.
  21. """
  22. retries_needed = []
  23. today = datetime.date.today()
  25. for task in tasks:
  26. last_attempt_date = task['last_attempt'].date()
  27. retry_interval = task['retry_interval_days']
  29. # Calculate time since last attempt
  30. time_since_last_attempt = today - last_attempt_date
  31. days_since_last_attempt = time_since_last_attempt.days
  33. # Check if retry is needed
  34. if days_since_last_attempt >= retry_interval:
  35. # Compare form field values (example comparison)
  36. if task['field1'] != "expected_value" or task['field2'] != 10:
  37. retries_needed.append({
  38. 'task_id': task['task_id'],
  39. 'reason': "Form field values do not match expected values",
  40. 'next_retry_time': today + datetime.timedelta(days=retry_interval)
  41. })
  42. print(f"Task {task['task_id']} needs retry. Next retry: {today + datetime.timedelta(days=retry_interval)}")
  43. else:
  44. print(f"Task {task['task_id']} does not need retry. Last attempt: {last_attempt_date}, Retry interval: {retry_interval}, Days since last attempt: {days_since_last_attempt}")
  46. return retries_needed
  49. if __name__ == '__main__':
  50. # Example usage
  51. tasks_data = [
  52. {
  53. 'task_id': 1,
  54. 'last_attempt': datetime.datetime(2024, 1, 15),
  55. 'retry_interval_days': 7,
  56. 'field1': "expected_value",
  57. 'field2': 10
  58. },
  59. {
  60. 'task_id': 2,
  61. 'last_attempt': datetime.datetime(2024, 1, 20),
  62. 'retry_interval_days': 7,
  63. 'field1': "different_value",
  64. 'field2': 10
  65. },
  66. {
  67. 'task_id': 3,
  68. 'last_attempt': datetime.datetime(2024, 1, 28),
  69. 'retry_interval_days': 7,
  70. 'field1': "expected_value",
  71. 'field2': 10
  72. },
  73. {
  74. 'task_id': 4,
  75. 'last_attempt': datetime.datetime(2024, 2, 1),
  76. 'retry_interval_days': 7,
  77. 'field1': "expected_value",
  78. 'field2': 10
  79. }
  80. ]
  82. retries = compare_maintenance_tasks(tasks_data)
  83. print("\nTasks needing retry:")
  84. for retry_task in retries:
  85. print(retry_task)

Add your comment