Spaces:
Running
Running
Update run_agentic_pipeline.py
Browse files- run_agentic_pipeline.py +15 -0
run_agentic_pipeline.py
CHANGED
@@ -163,6 +163,21 @@ async def run_agentic_pipeline_autonomously(current_token_state_val, orchestrati
|
|
163 |
)
|
164 |
return
|
165 |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
166 |
try:
|
167 |
# Parameters for 'Sempre' filter for the agentic pipeline
|
168 |
date_filter_val_agentic = "Sempre"
|
|
|
163 |
)
|
164 |
return
|
165 |
|
166 |
+
#DA AGGIORNARE CON RIPORTO DEI DATI PRESI DA BUBBLE E FORMATTATI NEL MODO GIUSTO
|
167 |
+
if not current_token_state_val.get("agentic_pipeline_should_run_now", False):
|
168 |
+
logging.warning("no need for agentic pipeline to run. Data stored in db.")
|
169 |
+
yield (
|
170 |
+
gr.update(value="Data stored in db"),
|
171 |
+
gr.update(choices=[], value=[], interactive=False),
|
172 |
+
gr.update(value="Data stored in db"),
|
173 |
+
None, [], [], "Pipeline AI: Data stored in db"
|
174 |
+
)
|
175 |
+
return
|
176 |
+
|
177 |
+
else:
|
178 |
+
continue
|
179 |
+
|
180 |
+
|
181 |
try:
|
182 |
# Parameters for 'Sempre' filter for the agentic pipeline
|
183 |
date_filter_val_agentic = "Sempre"
|