@@ -9,23 +9,23 @@ import (
99 "github.com/pixlise/core/v4/core/fileaccess"
1010)
1111
12- func Example_RunJob_NoConfig () {
12+ func Example_jobrunner_RunJob_NoConfig () {
1313 os .Setenv (JobConfigEnvVar , "" )
1414 fmt .Printf ("%v\n " , RunJob (false ))
1515
1616 // Output:
1717 // JOB_CONFIG env var not set
1818}
1919
20- func Example_RunJob_BadConfig () {
20+ func Example_jobrunner_RunJob_BadConfig () {
2121 os .Setenv (JobConfigEnvVar , "{ \" Some\" : \" unfinished JSON }" )
2222 fmt .Printf ("%v\n " , RunJob (false ))
2323
2424 // Output:
2525 // Failed to parse env var JOB_CONFIG: unexpected end of JSON input
2626}
2727
28- func Example_RunJob_NoCommand () {
28+ func Example_jobrunner_RunJob_NoCommand () {
2929 cfg := JobConfig {
3030 JobId : "Job001" ,
3131 }
@@ -44,7 +44,7 @@ func Example_RunJob_NoCommand() {
4444 // Job: No command specified
4545}
4646
47- func Example_RunJob_BadInputLocalPath () {
47+ func Example_jobrunner_RunJob_BadInputLocalPath () {
4848 cfg := JobConfig {
4949 JobId : "Job001" ,
5050 RequiredFiles : []JobFilePath {{LocalPath : "" , RemoteBucket : "test-piquant" , RemotePath : "jobs/Job001/input.csv" }},
@@ -68,7 +68,7 @@ func Example_RunJob_BadInputLocalPath() {
6868 // Job: No localPath specified
6969}
7070
71- func Example_RunJob_BadInputRemotePath () {
71+ func Example_jobrunner_RunJob_BadInputRemotePath () {
7272 cfg := JobConfig {
7373 JobId : "Job001" ,
7474 RequiredFiles : []JobFilePath {{LocalPath : "input.csv" , RemoteBucket : "test-piquant" , RemotePath : "jobs/Job001/input.csv" }},
@@ -93,7 +93,7 @@ func Example_RunJob_BadInputRemotePath() {
9393 // Job: Failed to download s3://test-piquant/jobs/Job001/input.csv: Not found
9494}
9595
96- func Example_RunJob_UploadNotThere () {
96+ func Example_jobrunner_RunJob_UploadNotThere () {
9797 cfg := JobConfig {
9898 JobId : "Job001" ,
9999 Command : NoOpCommand ,
@@ -121,7 +121,7 @@ func Example_RunJob_UploadNotThere() {
121121 // Job: Job Job001 failed to generate/upload output files: nofile.txt
122122}
123123
124- func Example_RunJob_DownloadUploadOK () {
124+ func Example_jobrunner_RunJob_DownloadUploadOK () {
125125 // Before we do anything, ensure the file is in S3
126126 sess , err := awsutil .GetSession ()
127127 fmt .Printf ("GetSession: %v\n " , err )
0 commit comments