Skip to content

Commit

Permalink
Fix required states
Browse files Browse the repository at this point in the history
  • Loading branch information
aarontp committed Oct 8, 2023
1 parent 49a32e7 commit 106f619
Show file tree
Hide file tree
Showing 7 changed files with 13 additions and 11 deletions.
2 changes: 1 addition & 1 deletion turbinia/workers/analysis/jenkins.py
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@
class JenkinsAnalysisTask(TurbiniaTask):
"""Task to analyze a Jenkins install."""

# Input is typically extract artifact so does not need to be MOUNTED
# Does not need to be MOUNTED as this Task uses extract_files()
REQUIRED_STATES = [state.ATTACHED, state.CONTAINER_MOUNTED]

TASK_CONFIG = {
Expand Down
4 changes: 2 additions & 2 deletions turbinia/workers/analysis/jupyter.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@
class JupyterAnalysisTask(TurbiniaTask):
"""Task to analyze a Jupyter Notebook config."""

# Input is typically extracted artifact so does not need to be MOUNTED
REQUIRED_STATES = [state.ATTACHED, state.MOUNTED, state.CONTAINER_MOUNTED]
# Input Evidence is ExportedFileArtifact so does not need to be pre-processed.
REQUIRED_STATES = []

def run(self, evidence, result):
"""Run the Jupyter worker.
Expand Down
4 changes: 2 additions & 2 deletions turbinia/workers/analysis/wordpress_access.py
Original file line number Diff line number Diff line change
Expand Up @@ -30,8 +30,8 @@
class WordpressAccessLogAnalysisTask(TurbiniaTask):
"""Task to analyze Wordpress access logs."""

# Input is typically extracted artifact so does not need to be MOUNTED
REQUIRED_STATES = [state.ATTACHED, state.CONTAINER_MOUNTED]
# Input Evidence is ExportedFileArtifact so does not need to be preprocessed.
REQUIRED_STATES = []

timestamp_regex = re.compile(r'\[(?P<timestamp>.+)\]')

Expand Down
3 changes: 2 additions & 1 deletion turbinia/workers/analysis/wordpress_creds.py
Original file line number Diff line number Diff line change
Expand Up @@ -34,8 +34,9 @@
class WordpressCredsAnalysisTask(TurbiniaTask):
"""Task to analyze the credentials of a Wordpress instance."""

# Does not need to be MOUNTED as uses extract_files()
REQUIRED_STATES = [
state.ATTACHED, state.MOUNTED, state.CONTAINER_MOUNTED, state.DECOMPRESSED
state.ATTACHED, state.CONTAINER_MOUNTED, state.DECOMPRESSED
]

TASK_CONFIG = {
Expand Down
4 changes: 2 additions & 2 deletions turbinia/workers/redis.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@
class RedisAnalysisTask(TurbiniaTask):
"""Task to analyze a Redis configuration file."""

# Input is typically extracted artifact so does not need to be MOUNTED
REQUIRED_STATES = [state.ATTACHED, state.CONTAINER_MOUNTED]
# Input Evidence is ExportedFileArtifact so does not need to be pre-processed.
REQUIRED_STATES = []

def run(self, evidence, result):
"""Run the Redis configuration analysis worker.
Expand Down
3 changes: 2 additions & 1 deletion turbinia/workers/sshd.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,8 @@
class SSHDAnalysisTask(TurbiniaTask):
"""Task to analyze a sshd_config file."""

REQUIRED_STATES = [state.ATTACHED, state.MOUNTED, state.CONTAINER_MOUNTED]
# Input Evidence is ExportedFileArtifact so does not need to be pre-processed.
REQUIRED_STATES = []

def run(self, evidence, result):
"""Run the sshd_config analysis worker.
Expand Down
4 changes: 2 additions & 2 deletions turbinia/workers/tomcat.py
Original file line number Diff line number Diff line change
Expand Up @@ -29,8 +29,8 @@
class TomcatAnalysisTask(TurbiniaTask):
"""Task to analyze a Tomcat file."""

# Input is typically extracted artifact so does not need to be MOUNTED
REQUIRED_STATES = [state.ATTACHED, state.CONTAINER_MOUNTED]
# Input Evidence is ExportedFileArtifact so does not need to be pre-processed.
REQUIRED_STATES = []

def run(self, evidence, result):
"""Run the Tomcat analysis worker.
Expand Down

0 comments on commit 106f619

Please sign in to comment.