|
@@ -97,12 +97,12 @@ def _check_quota(scene: SceneEnum, capability: CapabilityEnum = CapabilityEnum.D
|
|
|
INSERT INTO workflow_daily_quota (scene, capability, content_type, quota_date, quota_limit, used_count, locked)
|
|
INSERT INTO workflow_daily_quota (scene, capability, content_type, quota_date, quota_limit, used_count, locked)
|
|
|
VALUES (%s, %s, %s, %s, %s, %s, %s)
|
|
VALUES (%s, %s, %s, %s, %s, %s, %s)
|
|
|
"""
|
|
"""
|
|
|
- cursor.execute(insert_sql, (scene_value, capability_value, content_type_value, quota_date, 10, 0, 0))
|
|
|
|
|
- quota_limit = 10
|
|
|
|
|
|
|
+ cursor.execute(insert_sql, (scene_value, capability_value, content_type_value, quota_date, 100, 0, 0))
|
|
|
|
|
+ quota_limit = 100
|
|
|
current_used_count = 0
|
|
current_used_count = 0
|
|
|
is_locked = 0
|
|
is_locked = 0
|
|
|
else:
|
|
else:
|
|
|
- quota_limit = quota_record.get('quota_limit', 10)
|
|
|
|
|
|
|
+ quota_limit = quota_record.get('quota_limit', 100)
|
|
|
current_used_count = quota_record.get('used_count', 0)
|
|
current_used_count = quota_record.get('used_count', 0)
|
|
|
is_locked = quota_record.get('locked', 0)
|
|
is_locked = quota_record.get('locked', 0)
|
|
|
|
|
|
|
@@ -209,7 +209,7 @@ def _trigger_topic_decode_workflow(task_id: str) -> Dict[str, Any]:
|
|
|
"""发起解构任务(调用上游工作流服务)"""
|
|
"""发起解构任务(调用上游工作流服务)"""
|
|
|
try:
|
|
try:
|
|
|
# url = "http://192.168.81.96:8000/workflow/topic/decode"
|
|
# url = "http://192.168.81.96:8000/workflow/topic/decode"
|
|
|
- url = "http://supply-content-deconstruction-workflow.piaoquantv.com/workflow/topic/decode"
|
|
|
|
|
|
|
+ url = "http://supply-content-deconstruction-workflow.piaoquantv.com/decode/workflow/topic/decode"
|
|
|
params = {"taskId": task_id}
|
|
params = {"taskId": task_id}
|
|
|
|
|
|
|
|
resp = requests.get(url, params=params, timeout=10)
|
|
resp = requests.get(url, params=params, timeout=10)
|