Normally, if I want to define a command-line option for mrjob, I have to do like this:
class Calculate(MRJob):
def configure_args(self):
super(Calculate, self).configure_args()
self.add_passthru_arg("-t", "--time", help="output folder for time")
When I want to use the argument, I just need to call self.options.time
but it only works inside that class.
I want to track the time of the mrjob
and write the time into the json
file like this cal.py
:
from datetime import datetime
import json
import argparse
parser = argparse.ArgumentParser()
parser.add_argument("-t", "--time", help = "Output file")
args = parser.parse_args()
class Calculate(MRJob):
...
start_time = datetime.now()
Calculate.run()
execute_time = (datetime.now() - start_time).total_seconds()
data = {}
data["step1"] = execute_time
with open(args.time+'/time.json', 'w') as outfile:
json.dump(data, outfile)
When I run with this command:
python cal.py data/input/input.txt --output data/output --time data/output
I got this error:
usage: cal.py [-h] [-t TIME]
cal.py: error: unrecognized arguments: data/input/input.txt --output data/output
Then I found an answer about using parse_known_args()
and I tried it:
args, unknown = parser.parse_known_args()
Now, I got a new error. I believe this is from mrjob
because I did remove the argparse
and run the same command, it returns exactly like this:
usage: cal.py [options] [input files]
cal.py: error: unrecognized arguments: --time data/output
How can I define an argument without affecting the mrjob
class?
I found a workaround solution but I hope there will be a better way of doing this.
I have to define the argument again inside the mrjob
class so it can recognize it:
from datetime import datetime
import json
import argparse
parser = argparse.ArgumentParser()
parser.add_argument("-t", "--time", help = "Output file")
args, unknown = parser.parse_known_args()
class Calculate(MRJob):
def configure_args(self):
super(Calculate, self).configure_args()
self.add_passthru_arg("-t", "--time", help="output folder for time")
start_time = datetime.now()
Calculate.run()
execute_time = (datetime.now() - start_time).total_seconds()
data = {}
data["step1"] = execute_time
with open(args.time+'/time.json', 'w') as outfile:
json.dump(data, outfile)
And run with this command:
python cal.py data/input/input.txt --output data/output --time data/output