Skip to content

Commit

Permalink
Fix powerjob test when python is not available (#12315)
Browse files Browse the repository at this point in the history
  • Loading branch information
laurit authored Sep 23, 2024
1 parent 3633d2b commit faff2d9
Showing 1 changed file with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -207,9 +207,10 @@ void testPythonProcessor() throws Exception {
trace -> {
trace.hasSpansSatisfyingExactly(
span -> {
// not asserting status as it is either unset or error depending on whether python
// is available or not
span.hasName(String.format("%s.process", PythonProcessor.class.getSimpleName()))
.hasKind(SpanKind.INTERNAL)
.hasStatus(StatusData.unset())
.hasAttributesSatisfyingExactly(
attributeAssertions(
PythonProcessor.class.getName(), jobId, jobParam, PYTHON_PROCESSOR));
Expand All @@ -219,7 +220,6 @@ void testPythonProcessor() throws Exception {

@Test
void testHttpProcessor() throws Exception {

long jobId = 1;
String jobParam = "{\"method\":\"GET\"}";
TaskContext taskContext = genTaskContext(jobId, jobParam);
Expand All @@ -243,7 +243,6 @@ void testHttpProcessor() throws Exception {

@Test
void testFileCleanerProcessor() throws Exception {

long jobId = 1;
JSONObject params = new JSONObject();
params.put("dirPath", "/abc");
Expand Down Expand Up @@ -305,7 +304,6 @@ void testSpringDataSourceProcessor() throws Exception {

@Test
void testDynamicDataSourceProcessor() throws Exception {

long jobId = 1;
String jobParam = "{\"dirPath\":\"/abc\"}";
TaskContext taskContext = genTaskContext(jobId, jobParam);
Expand Down

0 comments on commit faff2d9

Please sign in to comment.