Skip to content

Commit 4561797

Browse files
committed
feat: add task_changed field at TaskInfo
Signed-off-by: ImMin5 <[email protected]>
1 parent f257cc5 commit 4561797

File tree

2 files changed

+13
-10
lines changed

2 files changed

+13
-10
lines changed

Dockerfile

+1-1
Original file line numberDiff line numberDiff line change
@@ -12,7 +12,7 @@ COPY pkg/*.txt ${PKG_DIR}/
1212

1313
RUN pip install --upgrade pip && \
1414
pip install --upgrade -r ${PKG_DIR}/pip_requirements.txt && \
15-
pip install --upgrade --pre spaceone-cost-analysis==2.0.dev128
15+
pip install --upgrade --pre spaceone-cost-analysis==2.0.dev204
1616

1717
COPY src ${SRC_DIR}
1818
WORKDIR ${SRC_DIR}

src/plugin/manager/job_manager.py

+12-9
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
from ..connector.aws_s3_connector import AWSS3Connector
88
from ..connector.spaceone_connector import SpaceONEConnector
99

10-
_LOGGER = logging.getLogger(__name__)
10+
_LOGGER = logging.getLogger("spaceone")
1111
_DEFAULT_DATABASE = "MZC"
1212

1313

@@ -72,16 +72,18 @@ def get_tasks(
7272
first_sync_month = self._get_start_month(options, start)
7373
task_options["start"] = first_sync_month
7474

75-
changed.append(
76-
{
77-
"start": first_sync_month,
78-
"filter": {"additional_info.Account ID": account_id},
79-
}
80-
)
75+
task_changed = {
76+
"start": first_sync_month,
77+
"filter": {"additional_info.Account ID": account_id},
78+
}
79+
8180
else:
8281
task_options["start"] = start_month
82+
task_changed = {"start": start_month}
8383

84-
tasks.append({"task_options": task_options})
84+
tasks.append(
85+
{"task_options": task_options, "task_changed": task_changed}
86+
)
8587

8688
changed.append({"start": start_month})
8789

@@ -133,7 +135,8 @@ def get_tasks_directory_type(
133135
"is_sync": "true",
134136
"task_type": "directory",
135137
}
136-
tasks.append({"task_options": task_options})
138+
task_changed = {"start": start_month}
139+
tasks.append({"task_options": task_options, "task_changed": task_changed})
137140

138141
changed.append({"start": start_month})
139142

0 commit comments

Comments
 (0)