Merge pull request #13 from ImMin5/master

Add task_changed field at TaskInfo

Author: ImMin5

Dockerfile

@@ -12,7 +12,7 @@ COPY pkg/*.txt ${PKG_DIR}/
 
 RUN pip install --upgrade pip && \
     pip install --upgrade -r ${PKG_DIR}/pip_requirements.txt && \
-    pip install --upgrade --pre spaceone-cost-analysis==2.0.dev128
+    pip install --upgrade --pre spaceone-cost-analysis==2.0.dev204
 
 COPY src ${SRC_DIR}
 WORKDIR ${SRC_DIR}

src/plugin/manager/job_manager.py

@@ -7,7 +7,7 @@
 from ..connector.aws_s3_connector import AWSS3Connector
 from ..connector.spaceone_connector import SpaceONEConnector
 
-_LOGGER = logging.getLogger(__name__)
+_LOGGER = logging.getLogger("spaceone")
 _DEFAULT_DATABASE = "MZC"
 
 
@@ -72,16 +72,18 @@ def get_tasks(
                     first_sync_month = self._get_start_month(options, start)
                     task_options["start"] = first_sync_month
 
-                    changed.append(
-                        {
-                            "start": first_sync_month,
-                            "filter": {"additional_info.Account ID": account_id},
-                        }
-                    )
+                    task_changed = {
+                        "start": first_sync_month,
+                        "filter": {"additional_info.Account ID": account_id},
+                    }
+
                 else:
                     task_options["start"] = start_month
+                    task_changed = {"start": start_month}
 
-                tasks.append({"task_options": task_options})
+                tasks.append(
+                    {"task_options": task_options, "task_changed": task_changed}
+                )
 
             changed.append({"start": start_month})
 
@@ -133,7 +135,8 @@ def get_tasks_directory_type(
                 "is_sync": "true",
                 "task_type": "directory",
             }
-            tasks.append({"task_options": task_options})
+            task_changed = {"start": start_month}
+            tasks.append({"task_options": task_options, "task_changed": task_changed})
 
         changed.append({"start": start_month})