Spaces:
Runtime error
Runtime error
Upload folder using huggingface_hub
Browse files- kafkaWorker.py +1 -2
kafkaWorker.py
CHANGED
|
@@ -31,7 +31,7 @@ def classify(data):
|
|
| 31 |
"experiences": str(data['cv']['experiences']),
|
| 32 |
"positions": str(positions),
|
| 33 |
"userMajors": str(userMajors),
|
| 34 |
-
"skills": str(data['cv']
|
| 35 |
"yoe": yoe
|
| 36 |
}
|
| 37 |
job = {
|
|
@@ -75,7 +75,6 @@ def consume_message():
|
|
| 75 |
for message in consumer:
|
| 76 |
try:
|
| 77 |
incoming_message = json.loads(json.loads(message.value.decode('utf-8')))
|
| 78 |
-
print(incoming_message)
|
| 79 |
data = incoming_message['data']
|
| 80 |
result = classify(data)
|
| 81 |
send_results_back(result, incoming_message['job_application_id'])
|
|
|
|
| 31 |
"experiences": str(data['cv']['experiences']),
|
| 32 |
"positions": str(positions),
|
| 33 |
"userMajors": str(userMajors),
|
| 34 |
+
"skills": str(data['cv']['skills']),
|
| 35 |
"yoe": yoe
|
| 36 |
}
|
| 37 |
job = {
|
|
|
|
| 75 |
for message in consumer:
|
| 76 |
try:
|
| 77 |
incoming_message = json.loads(json.loads(message.value.decode('utf-8')))
|
|
|
|
| 78 |
data = incoming_message['data']
|
| 79 |
result = classify(data)
|
| 80 |
send_results_back(result, incoming_message['job_application_id'])
|