Skip to content

Commit 0191830

Browse files
committed
Fix jobs Fusion SQL commands
1 parent 74bff92 commit 0191830

File tree

2 files changed

+4
-8
lines changed

2 files changed

+4
-8
lines changed

singlestoredb/fusion/handlers/job.py

Lines changed: 4 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -136,8 +136,8 @@ def run(self, params: Dict[str, Any]) -> Optional[FusionSQLResult]:
136136

137137
execution_interval_in_mins = None
138138
if params.get('execute_every'):
139-
execution_interval_in_mins = params['execute_every'][0]['interval']
140-
time_unit = params['execute_every'][-1]['time_unit'].upper()
139+
execution_interval_in_mins = params['execute_every']['interval']
140+
time_unit = params['execute_every']['time_unit'].upper()
141141
if time_unit == 'MINUTES':
142142
pass
143143
elif time_unit == 'HOURS':
@@ -292,8 +292,8 @@ def run(self, params: Dict[str, Any]) -> Optional[FusionSQLResult]:
292292

293293
timeout_in_secs = None
294294
if params.get('with_timeout'):
295-
timeout_in_secs = params['with_timeout'][0]['time']
296-
time_unit = params['with_timeout'][-1]['time_unit'].upper()
295+
timeout_in_secs = params['with_timeout']['time']
296+
time_unit = params['with_timeout']['time_unit'].upper()
297297
if time_unit == 'SECONDS':
298298
pass
299299
elif time_unit == 'MINUTES':

singlestoredb/tests/test_fusion.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -465,10 +465,6 @@ def test_create_drop_workspace_group(self):
465465
pass
466466

467467

468-
@unittest.skipIf(
469-
os.environ.get('SINGLESTOREDB_FUSION_ENABLE_HIDDEN', '0') == '0',
470-
'Hidden Fusion commands are not enabled.',
471-
)
472468
@pytest.mark.management
473469
class TestJobsFusion(unittest.TestCase):
474470

0 commit comments

Comments
 (0)