最新gaia代码

307c8969 · lixiaofang · dc127c0c · 7820b639 · 307c8969 · 307c8969
Commit 307c8969 authored Dec 17, 2019 by lixiaofang
Expand all Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 3 deletions

-f -f +0 -0

workspace.xml .idea/workspace.xml +0 -0

special_service_dbmw.py api/tool/special_service_dbmw.py +1 -3

No files found.
--- a/-f
+++ b/-f
--- a/.idea/workspace.xml
+++ b/.idea/workspace.xml
--- a/api/tool/special_service_dbmw.py
+++ b/api/tool/special_service_dbmw.py
@@ -14,16 +14,14 @@ from gm_dbmw_api.descriptor.source import GroupedSource, MySQLTableScanSource
 from gm_dbmw_api.descriptor.sink import CeleryV1Sink
 from gm_dbmw_api.descriptor.source import MySQLTableSource

-
 DB = settings.DATABASES['default']['NAME']

-
 sink_update_with_tag = CeleryV1Sink(
    task='api.tasks.special_service_dbmw.update_with_tag',
    key_list_param_name='ids',
    static_params_json='{}',
    broker_url=settings.BROKER_URL,
-    queue='',
+    queue='gaia-dbmw',
    unpack_input_tuple=True,
    batch_size_limit=20,
    flow_rate_limit=20.0,