GithubBackup/douyin-sparkflow
1
0
Fork 0
mirror of https://github.com/halfwaystudent/douyin-sparkflow.git synced 2026-09-05 23:49:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update send console workflow and redesign dashboard UI

Browse Source
This commit is contained in:
Rixuan Shao
2026-05-18 22:24:04 +08:00
parent 9e3cc85215
commit 0397ec60e9
7 changed files with 1992 additions and 1340 deletions
Download Patch File Download Diff File Expand all files Collapse all files
DouYinSparkFlow/core/tasks.py
+12 -1
View File
@@ -374,7 +374,18 @@ def _select_due_targets(user, send_window, now):
microsecond=0,
)
if now < window_start or now > window_end:
return [], [], [(target, _scheduled_send_time(user, target, send_window, now)) for target in targets], []
already_sent = []
pending_targets = []
queued_failures = []
for target_name in targets:
if _target_sent_today(user, target_name, now):
already_sent.append(target_name)
continue
if _target_failed_today(user, target_name, now):
queued_failures.append(target_name)
continue
pending_targets.append((target_name, _scheduled_send_time(user, target_name, send_window, now)))
return [], already_sent, pending_targets, queued_failures
due_targets = []
already_sent = []