ExternalVendorCode/onefuzz
1
0
Fork 0
mirror of https://github.com/microsoft/onefuzz.git synced 2025-06-16 20:08:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

slightly trim state update logs (#68)

Browse Source
This commit is contained in:
bmc-msft
2020-10-01 15:59:49 -04:00
committed by GitHub
parent e234240b36
commit 22ee2975ef
3 changed files with 5 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/api-service/__app__/onefuzzlib/updates.py
View File

@ -78,6 +78,8 @@ def execute_update(update: Update) -> None:
if update.update_type == UpdateType.Scaleset: if update.update_type == UpdateType.Scaleset:
return return
logging.info("performing queued update: %s", update)
if update.update_type in update_objects: if update.update_type in update_objects:
if update.PartitionKey is None or update.RowKey is None: if update.PartitionKey is None or update.RowKey is None:
raise Exception("unsupported update: %s" % update) raise Exception("unsupported update: %s" % update)
@ -103,8 +105,3 @@ def execute_update(update: Update) -> None:
return return
raise NotImplementedError("unimplemented update type: %s" % update.update_type.name) raise NotImplementedError("unimplemented update type: %s" % update.update_type.name)
def perform_update(update: Update) -> None:
logging.info("performing queued update: %s", update)
execute_update(update)

2
src/api-service/__app__/scaleset_events/__init__.py
View File

@ -23,7 +23,7 @@ def process_scaleset(scaleset: Scaleset) -> None:
if scaleset.state in ScalesetState.needs_work(): if scaleset.state in ScalesetState.needs_work():
logging.info( logging.info(
"executing scaleset state: %s - %s", "exec scaleset state: %s - %s",
scaleset.scaleset_id, scaleset.scaleset_id,
scaleset.state.name, scaleset.state.name,
) )

4
src/api-service/__app__/update_queue/__init__.py
View File

@ -8,13 +8,13 @@ import json
import azure.functions as func import azure.functions as func
from ..onefuzzlib.dashboard import get_event from ..onefuzzlib.dashboard import get_event
from ..onefuzzlib.updates import Update, perform_update from ..onefuzzlib.updates import Update, execute_update
def main(msg: func.QueueMessage, dashboard: func.Out[str]) -> None: def main(msg: func.QueueMessage, dashboard: func.Out[str]) -> None:
body = msg.get_body() body = msg.get_body()
update = Update.parse_obj(json.loads(body)) update = Update.parse_obj(json.loads(body))
perform_update(update) execute_update(update)
event = get_event() event = get_event()
if event: if event: