2iz d Z ddlmZmZmZmZmZmZmZm Z m
Z
m Z m Z m
Z
mZmZmZmZmZmZmZmZ ddlmZ ddlmZ ddlZddlm Z ddl m Z G d d e Z dS )
z
Schedule Editor Dialog for Python Scheduler
Create and edit schedules for individual jobs or groups (with inline group creation)
)QDialog QVBoxLayout QHBoxLayout QFormLayoutQLabel QLineEdit QTextEdit QComboBox QPushButton QMessageBox QGroupBox QRadioButton QButtonGroupQStackedWidget QListWidgetQListWidgetItemQAbstractItemView QCheckBoxQSpinBoxQWidget)Qt)loggerN)SchedulerDatabase)SchedulerConfigc e Zd ZdZd dedededef fd
Zd Zd Z d
Z
d Z d Z d
Z
d ZdefdZd Zd Zd Zd Zd Zd ZdefdZdefdZd Z xZS ) ScheduleEditorDialogz6Dialog for creating/editing schedules (jobs or groups)Ndbconfig schedule_idpre_selected_job_idc t | || _ || _ || _ || _ |d u| _ | | j rdnd | dd | d |
| j r| d S d S )Nz
Edit Schedulez New Schedulei iX T) super__init__r r r r is_edit_modesetWindowTitlesetMinimumSizesetModal _setup_ui_load_schedule_data)selfparentr r r r __class__s 1c:\PYTHON\Scheduler\gui\schedule_editor_dialog.pyr# z ScheduleEditorDialog.__init__ s
 't 3
t/@ TOOnUUU C%%%
d ' $ $ & & & & & ' ' c R& t | }t d }t }t | _ | j d | d| j t | _ | j d | j d | d| j |
| | | t d }t }t }t | | _ t d | _ | j d | j j | j | j | j d
| | j t d | _ | j j | j | j | j d | | j t d
| _ | j j | j | j | j d | | j t d | _ | j j | j | j | j d | | j | | | t7 | _ t; }t | }t= | _ | j d | j j | j! | tE d | | j | | j | t; } t | }
t } t | | _# t d | _$ | j$ d | j$ j | j% | j# | j$ d
| | j$ t d | _& | j& j | j% | j# | j& d | | j& |
| t7 | _' t; } t | }
t= | _( | j( d |
tE d |
| j( |
| j' | t; }t | }t | _) | j) d | tE d | | j) t }| tE d t= | _* | j* + g d | | j* | | | | tE d tY | _- | j- . t^ j0 j1 | j- d | | j- t }te d | _3 | j3 j4 | j5 | | j3 te d | _6 | j6 j4 | j7 | | j6 | | | | tE d tY | _8 | j8 d | | j8 t }te d | _9 | j9 j4 | j: | | j9 te d! | _; | j; j4 | j< | | j; | | | | j' | |
| j' | j | t; }t | }t= | _= | j= d" | tE d# | | j= | | j | t; }t | }t= | _> | j> d$ | tE d% | | j> | | j | | | j |
| | | t d& }t }t }| tE d' t= | _? | j? + g d( | j? j@ | jA | | j? | | | t7 | _B t; }t | }t | _C | jC d) | tE d* | | jC tE d+ } | D d, | | tE d- } | E d | D d. | | | | jB | t; } t | } t | _G | jG H d
| jG I d/ | d0| jG t | _J | jJ H d
| jJ I d1 | d2| jJ t | _K | jK H d
| jK I d3 | d4| jK t | _L | jL H d
| jL I d5 | d6| jL t | _M | jM H d
| jM I d5 | d7| jM tE d8 } | D d, | N d | d9| | jB | t; }!t |! }"tE d: }#|#D d; |#N d |" |# |" | jB |! | | jB t d< | _P | jP d | | jP |
| | | t }$|$ te | jQ rd=nd> | _R | jR D d? | jR j4 | jS |$ | jR te d@ }%|%j4 | jT |$ |% | |$ | U | V | W | X dAS )BzSetup dialog UIzBasic Informationze.g., Daily ETL PipelinezSchedule Name:zOptional description...< z Description:zWhat to ExecutezExecute Single JobTr zExecute Job Group (Chain) zExecute Backup Profile zExecute Sync Profile zSelect a job...z Select Job:zUse Existing GroupzCreate New GroupzSelect a group...z
Select Group:ze.g., Data Processing Chainz Group Name:zError Handling:)
stop_on_errorcontinue_on_errorskip_remainingzAvailable Jobs:d u Add Selected ↓u Remove Selected ↑z Jobs in Group (execution order):u Move Up ↑u
Move Down ↓zSelect a backup profile...zSelect Backup Profile:zSelect a sync profile...zSelect Sync Profile:zWhen to ExecutezSchedule Type:cronintervalmanualz$e.g., 0 2 * * * or 30 14 * * mon-frizCron Expression:u Format: minute hour day month day_of_week
Examples:
• 0 8 * * * = Daily at 8:00 AM
• 30 14 * * mon-fri = Weekdays at 2:30 PM
• 0 9 * * mon,wed,fri = Mon/Wed/Fri at 9:00 AMz color: #666; font-size: 10px;zICron Expression Helper (crontab.guru)z color: #2196F3; font-size: 10px;4 zWeeks:im zDays: zHours:; zMinutes:zSeconds:z{Specify the interval duration.
At least one value must be non-zero.
Example: 2 weeks = execute every 2 weeks from first run z[Manual execution only - no automatic scheduling.
Use 'Run Now' button to execute on demand.z color: #666; font-style: italic;z)Enabled (schedule will run automatically)SaveCreatezNbackground-color: #4CAF50; color: white; padding: 8px 20px; font-weight: bold;CancelN)Yr r
r r
name_inputsetPlaceholderTextaddRowr description_inputsetMaximumHeight setLayout addWidgetr r target_button_groupr job_radio
setCheckedtoggledconnect_on_target_type_changed addButton group_radio backup_radio
sync_radio
addStretch addLayoutr target_stackr r
job_combocurrentIndexChanged_on_job_selectedr group_selection_button_groupexisting_group_radio_on_group_selection_changednew_group_radio group_stackexisting_group_combogroup_name_inputgroup_error_comboaddItemsr available_jobs_listsetSelectionModer
SelectionModeMultiSelectionr add_to_group_btnclicked_add_jobs_to_groupremove_from_group_btn_remove_jobs_from_groupgroup_jobs_list move_up_btn _move_job_up
move_down_btn_move_job_down backup_combo
sync_comboschedule_type_combocurrentTextChanged_on_schedule_type_changedschedule_config_stack
cron_input
setStyleSheetsetOpenExternalLinksr interval_weeks
setMinimum
setMaximum
interval_daysinterval_hoursinterval_minutesinterval_seconds setWordWrapr enabled_checkboxr$ save_btn_save_schedulereject
_load_jobs _load_groups_load_backup_profiles_load_sync_profiles)&r* layout basic_group basic_layout target_group
target_layout radio_layoutjob_pagejob_page_layout
group_pagegroup_page_layoutgroup_radio_layoutexisting_group_widgetexisting_group_layoutnew_group_widgetnew_group_layout error_layoutadd_remove_layout order_layout backup_pagebackup_page_layout sync_pagesync_page_layoutschedule_groupschedule_layout type_layout cron_widget cron_layout cron_help cron_linkinterval_widgetinterval_layout
interval_help
manual_widget
manual_layout manual_labelactions_layout
cancel_btns& r- r( z ScheduleEditorDialog._setup_ui* s T"" 344 "}} #++ **+EFFF ,do>>>!* 112KLLL //333ND,BCCC l+++%%% !!233 #
#}} #/#5#5 %&:;; !!$''' &&t'CDDD **4>1=== t~...'(CDD (()EFFF **4+;Q??? t /000 ()A B B !))$*FGGG **4+> ''(DEEE **4?A>>> t/// !!! --- + , , 99%h//" ))*;<<< *2243HIII!!& "7"7888!!$.111""$$$ ##H--- YY
'
3 3 )]],8,>,>)$01E$F$F! !,,T222 !)11$2RSSS )33D4MqQQQ$$T%>??? +,> ? ? $,,T-MNNN )33D4H!LLL$$T%9:::##$6777 *++ !( +,A B B $-KK! !445HIII ''(?(?@@@ ''(ABBB ((*** ""#8999 #99&'788 !* 001NOOO""6-#8#8999""4#8999 #}} v&7 8 8999!* '' )
)
)
t 5666 !!!""<000 ""6*;#<#<===#.== 112C2Q2`aaa 11#666""4#;<<< (MM +,> ? ? %--d.EFFF##D$9:::%01F%G%G" "*2243OPPP##D$>???$$&&&""#4555 ""6*L#M#MNNN *}} --c222""4#7888 #}} &}55 (():;;; t /000 ( 9 9 "**4+>??? t 1222 !!!""<000 ""#3444##D$4555 ##J/// ii ( 5 5 %KK ,,-IJJJ$$V,D%E%EFFF$$T%6777%%''' ##K000 II &y11#++ **+EFFF""6*@#A#ABBB""4?333##%%% ##I... 1222 }--- &&& ##455%-- "mm f%5 6 6777#,;; ))*H*H*HIII 3;;D>>>
7
7&#f+'I'ISY'I'I'IJJ R_ 5s4yAAA(006666 '
F++D,DEEEEE
F
F 5 5 5 L333 4 4 4 4 4 4 4 4 4 5s CC
D!C>>Dc | j 5 }| d }d | D }ddd n # 1 swxY w Y |D ]\}| j |d }| j |d dt | d|d ]dS # t $ r"}t j
d| Y d}~dS d}~ww xY w) zLoad existing groupsz&SELECT * FROM job_groups ORDER BY namec , g | ]}t | S )dict).0rows r-
z5ScheduleEditorDialog._load_groups..{ s AAA$s))AAAr. Nr r z (z jobs)zError loading groups: ) r _get_connectionexecutefetchallget_job_group_membersr_ r lenr r r )r* conncursorgroupsgroupmembersr s r- r z!ScheduleEditorDialog._load_groupsv sq
7((**
Bd &NOOAAv/@/@AAA
B
B
B
B
B
B
B
B
B
B
B
B
B
B
B
'77d DD)11 V}<<G <<<$K
7 7 7 L5!55 6 6 6 6 6 6 6 6 6 7s; C 4A C A C "A #A"C
C3C..C3c | j }|D ]1}|d r'| j |d |d 2| j dk r7| j dd | j d dS dS # t $ r"}t j d| Y d}~dS d}~ww xY w) z"Load backup profiles for selectionenabledr r r (No enabled profiles)NFz Error loading backup profiles: ) r get_all_backup_profilesrq r count
setEnabledr r r r* profilesprofiler s r- r z*ScheduleEditorDialog._load_backup_profiles s @w6688H#
N
N9% N%--gfowt}MMM &&((A--!))*A4HHH!,,U33333 .- @ @ @ L>1>> ? ? ? ? ? ? ? ? ? @s B B% %
C/C Cc x | j | j }|D ]1}|d r'| j |d |d 2| j dk r7| j dd | j d dS | j d dS # t $ rW}t j d | | j d
d | j d Y d}~dS d}~ww xY w) z Load sync profiles for selectionr r r r r NFTz Error loading sync profiles: z(Error loading profiles))
rr clearr get_all_sync_profilesr r r r r r r s r- r z(ScheduleEditorDialog._load_sync_profiles sQ . O ! ! # # #w4466H#
L
L9% LO++GFOWT]KKK$$&&!++''(?FFF**511111**400000 . . . L<<< = = = O # #$> E E E O & &u - - - - - - - - - .s B8C <C
D9"A D44D9c | j r | j d dS | j r | j d dS | j r | j d dS | j r | j d dS dS )zHandle target type changer r1 r2 r3 N)rK isCheckedrV setCurrentIndexrQ rR rS r* s r- rO z,ScheduleEditorDialog._on_target_type_changed s > # # % % 1 - -a 0 0 0 0 0
'
'
)
) 1 - -a 0 0 0 0 0
(
(
*
* 1 - -a 0 0 0 0 0
_
&
&
(
( 1 - -a 0 0 0 0 0 1 1r. c | j r | j d dS | j d dS )z"Handle group selection type changer r1 N)r[ r r^ r r s r- r\ z0ScheduleEditorDialog._on_group_selection_changed sS $ . . 0 0 0 , ,Q / / / / / , ,Q / / / / /r.
schedule_typec l dddd}| |d }t j d| d| | j | | j t j d| j j j dS ) zHandle schedule type changer r1 r2 r8 zSchedule type changed to 'z ', switching to stack index zCurrent widget: N) getr debugrv r
currentWidgetupdateGeometryr, __name__)r* r type_mapindexs r- ru z.ScheduleEditorDialog._on_schedule_type_changed s 1:: ]A.. d-dd]bddeee "225999 "0022AACCC g(B(P(P(R(R(\(egghhhhhr. c | j s| j rdS | j }|r| | dS dS )z?When job is selected from combo, pre-populate schedule settingsN)r$ r rW currentDatar )r* job_ids r- rY z%ScheduleEditorDialog._on_job_selected s] 8 F ++-- 0 ' ' / / / / / 0 0r. c | j }|sdS |D ]}t | }| t
j j | t
j j | j
| | j | }| j | dS )zAdd selected jobs to groupN)
rc
selectedItemsr textr r r r datarl r r takeItemr* selected_itemsr new_itemr s r- ri z'ScheduleEditorDialog._add_jobs_to_group s 1??AA F" 3 3D&tyy{{33H R_ 5tyy AY7Z7Z [ [ [ ( ( 2 2 2*..t44C $ - -c 2 2 2 2
3 3r. c | j }|sdS |D ]}t | }| t
j j | t
j j | j
| | j | }| j | dS )z Remove selected jobs from groupN)
rl r r r r r r r r rc r r r r s r- rk z,ScheduleEditorDialog._remove_jobs_from_group s -;;== F" / /D&tyy{{33H R_ 5tyy AY7Z7Z [ [ [ $ , ,X 6 6 6&**400C ) )# . . . .
/ /r. c | j }|dk rW| j | }| j |dz
| | j |dz
dS dS )zMove selected job upr r1 N)rl
currentRowr
insertItem
setCurrentRowr* current_rowr s r- rn z!ScheduleEditorDialog._move_job_up sz *5577 ??'00==D + +K!OT B B B . .{Q ? ? ? ? ? ?r. c 6 | j }|| j dz
k r]|dk rY| j | }| j |dz | | j |dz dS dS dS )zMove selected job downr1 r N)rl r r r r r r s r- rp z#ScheduleEditorDialog._move_job_down s *5577 -33559 9 9kQ>N>N'00==D + +K!OT B B B . .{Q ? ? ? ? ? : 9>N>Nr. c | j | j }|s5t j | dd| j d | dS | j |d |d r | j |d |d dk r\| j
d | j
|d
}|d k r| j | nB|d d k r[| j d | j
|d
}|d k r| j | n|d d
k r[| j d | j
|d
}|d k r| j | nt| j d | j d | j
|d
}|d k r| j | | j |d t1 |d t2 rt5 j |d n|d }|d dk r/| j | dd n|d dk r| j | dd | j | dd | j! | dd | j" | dd | j# | dd | j$ |d dS # tJ $ rO}tM j' d| t j( | dd| | Y d}~dS d}~ww xY w)z'Load existing schedule data for editingErrorz Schedule z
not foundNr description target_typer T target_idr backup_profile sync_profiler schedule_configr9 r? r: weeksdayshoursminutessecondsr z Error loading schedule data: zFailed to load schedule: ))r get_scheduler r warningr rC setTextrF setPlainTextrK rL rW findDatar rR rq rS rr rQ r[ r_ rs setCurrentText
isinstancestrjsonloadsrw r rz setValuer} r~ r r r r r r critical)r* scheduler r r s r- r) z(ScheduleEditorDialog._load_schedule_data s$ 5 w++D,<==H
#D'3[t?O3[3[3[\\\
O # #HV$4 5 5 5
&
M&33H]4KLLL
&%//))$/// //0EFFA::N225999-(,<<<!,,T222 )228K3HIIA::%55e<<<-(N::**4000 00+1FGGA::O33E::: ++D111)44T::: 1::8K;PQQA::-==eDDD
$ 3 3H_4M N N N@J8TeKfhk@l@l NTZ): ;<<(>????/*j88#,,VZZ-C-CDDD"++FJJvq,A,ABBB#,,VZZ-C-CDDD%..vzz)Q/G/GHHH%..vzz)Q/G/GHHH ! , ,Xi-@ A A A A A L<<< = = = w0OA0O0O P P P KKMMMMMMMMM s AO6 N O6 6
Q AQ
Qreturnc | j s1t j | dd | j dS | j r7| j dk rt j | dd dS n| j
rP| j dk s| j t j | dd dS n/| j
rO| j dk s| j t j | dd dS n| j r6| j dk rt j | dd dS nx| j st j | dd
dS | j dk rt j | dd dS | j }|d k rD| j st j | dd
dS n|dk r| j dk r| j dk ro| j dk rR| j dk r5| j dk rt j | dd dS dS )zValidate form inputsValidation ErrorzSchedule name is requiredFr zPlease select a jobNz Please select a backup profile Please select a sync profilezPlease select a groupzGroup name is requiredz(Please add at least one job to the groupr9 zCron expression is requiredr: z*Please specify at least one interval valueT) rC r stripr r setFocusrK r rW currentIndexrR rq r rS rr r[ r_ r` rl r rs currentTextrw rz valuer} r~ r r )r* r s r- _validate_inputsz%ScheduleEditorDialog._validate_inputs7 sU ##%%++-- &8:U V V V O $ $ & & &5 > # # % % !~**,,q00#D*<>STTT u 1
(
(
*
* ! --//!33t7H7T7T7V7V7^#D*<>^___ u 8_ _
&
&
(
( !++--11T_5P5P5R5R5Z#D*<>\]]] u 6[ (2244
!,99;;a?? '.@BYZZZ 5 @ ,113399;; ! '.@BZ[[[ 5'--//144 '.@Blmmm 5 0<<>>
F " "?''))//11
#D*<>[\\\ u
j
(
(#))++q00"((**a//#))++q00%++--22%++--22#D*<>jkkk utr. r c | j | }|st j d| d dS | j d | j | }|dk r| j | | j
s#| j d|d |d r| j
|d t |d t rt! j |d n|d }|d d
k r3| d
d }|r| j | n|d d k r| j | d
d | j | dd | j | dd | j | dd | j | dd n.# t4 $ r!}t j d| Y d}~nd}~ww xY wt j d| dS # t4 $ r"}t j d| Y d}~dS d}~ww xY w)z3Pre-populate schedule settings from an existing jobzJob z not found for pre-populationNTr z
Schedule for r r r r9 r? r: r r r r r z*Could not parse schedule config from job: z'Pre-populated schedule editor from job z Error pre-populating from job: ) r get_jobr r rK rL rW r r rC r r rs r r r r r r rw rz r r} r~ r r r infor )r* r r r r cron_exprr s r- r z+ScheduleEditorDialog._pre_populate_from_jobi s * @'//&))C
Kf K K KLLL
N % %d + + +N++F33Ezz..u555 ?''))
G''(EF (E(EFFF ?#
U(77O8LMMMUCMcRcNdfiCjCj GTZ,=(> ? ? ?ps uF qGF?+v55$*JJvr$:$: $ ? O 3 3I > > > _-;; +44VZZ5K5KLLL *33FJJvq4I4IJJJ +44VZZ5K5KLLL -66vzz)Q7O7OPPP -66vzz)Q7O7OPPP U U UN#SPQ#S#STTTTTTTTU
KJ&JJ K K K K K @ @ @ L>1>> ? ? ? ? ? ? ? ? ? @sH 4J( B9J( 2E.I! J( !
J +JJ( J J( (
K2KKc * | sdS | j r d}| j }n| j r d}| j }n| j r7d}| j }|t j
| dd dS nc| j r d}| j }n-| j
d| j | j d } | j j d i |}t+ | j D ]`}| j | }| t4 j j }| j |||d
z at= j d | d
|d d}| j }|dk r.d| j! i}n|dk r|| j" # | j$ # | j% # | j& # | j' # d}ni }| j | j( ) pd||||| j* d} | j+ r^ | j j, | j- fi | t= j d| j- d
| d t j. | dd| d d nU | j j/ d i | }
t= j d|
d
| d t j. | dd| d d|
d | 0 dS # tb $ r;} t= j2 d| t j3 | dd | Y d} ~ dS d} ~ ww xY w) zSave schedule to databaseNr r r r r r zAuto-created for schedule: )r r error_handlingr1 )execution_orderzCreated inline group z: r r9 r: )r r r r r )r r r r r r r zUpdated schedule Successz
Schedule 'z' updated successfullyzCreated schedule z ' created successfully (ID: r zError saving schedule: r zFailed to save schedule: r )4r rK r rW r rR rq rS rr r r r[ r_ r` r r rC ra r r create_job_grouprangerl r r r r r r add_job_to_groupr r# rs rw rz r r} r~ r r rF toPlainTextr r$ update_scheduler informationcreate_scheduleacceptr r r ) r* r r
group_datair r r r
schedule_datar r s r- r z#ScheduleEditorDialog._save_schedule s $$&& FL Q~'')) !
* # N 6 6 8 8 ",,..
* . - 9 9 ; ; **,,
* , O 7 7 9 9 $ '.@B`aaaF % ,6688 *")K $ 9 E E G GII !% 5 : : < < B B D D'eT_EYEYE[E[EaEaEcEc'e'e*.*@*L*L*N*N" "J
!9 8 F F: F FI #4#7#=#=#?#? @ @ Y Y # 3 8 8 ; ;!%2?+C!D!D 00FTUVWTW0XXXXK Y Y YZPVEW Y YZZZ")K ! 4 @ @ B BM &&#)4?+?+?+A+A+G+G+I+I"J *,, ! 0 6 6 8 8 . 4 4 6 6 ! 0 6 6 8 8 # 4 : : < < # 4 : : < < # # #% ,,..4466 # 5 A A C C I I K K St * &!.#2 0::<< M
I''(8JJMJJJ [0@ [ [MRXDY [ [\\\'i9smTZF[9s9s9stttt 5dg 5 F F
F F V V V}V?T V VWWW'i :HmTZF[ :H :H zE :H :H :H I I I KKMMMMM Q Q Q L6166 7 7 7 w0OA0O0O P P P P P P P P P Qs B8Q
M9Q
R0R
R)NN) r
__module__ __qualname____doc__r r intr# r( r r r r rO r\ r ru rY ri rk rn rp r) boolr r r
__classcell__)r, s @r- r r s @@' '#4 'o '\_ ' ~A ' ' ' ' ' '$t# t# t#l 5 5 5,7 7 7"@ @ @ . . .* 1 1 10 0 0is i i i i0 0 0 3 3 3 / / / @ @ @@ @ @7 7 7r0$ 0 0 0 0d,@S ,@ ,@ ,@ ,@\QQ QQ QQ QQ QQ QQ QQr. r ) r6 PyQt6.QtWidgetsr r r r r r r r
r r r
r r r r r r r r r PyQt6.QtCorer logurur r
core.databaser core.configr r r r. r- r? s
+ + + + + + ' ' ' ' ' 'S Q S Q S Q S Q S Q7 S Q S Q S Q S Q S Qr.